Package | Description |
---|---|
org.apache.activemq.store |
The APIs which need to be implemented for persistent message stores for durable messaging
|
org.apache.activemq.store.amq |
The default Store implementation for ActiveMQ
|
org.apache.activemq.store.kahadaptor |
kaha implementation of message persistence for the broker
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<TransactionId,AMQTx> |
ReferenceStoreAdapter.retrievePreparedState() |
Modifier and Type | Method and Description |
---|---|
void |
ReferenceStoreAdapter.savePreparedState(java.util.Map<TransactionId,AMQTx> map)
Save prepared transactions
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<TransactionId,AMQTx> |
AMQTransactionStore.inflightTransactions |
Modifier and Type | Method and Description |
---|---|
AMQTx |
AMQTransactionStore.getTx(TransactionId txid,
Location location) |
AMQTx |
AMQTransactionStore.replayCommit(TransactionId txid,
boolean wasPrepared) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<TransactionId,AMQTx> |
AMQTransactionStore.getPreparedTransactions() |
Modifier and Type | Method and Description |
---|---|
void |
AMQTransactionStore.setPreparedTransactions(java.util.Map<TransactionId,AMQTx> preparedTransactions) |
Modifier and Type | Method and Description |
---|---|
AMQTx |
AMQTxMarshaller.readPayload(java.io.DataInput dataIn) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<TransactionId,AMQTx> |
KahaReferenceStoreAdapter.retrievePreparedState() |
Modifier and Type | Method and Description |
---|---|
void |
AMQTxMarshaller.writePayload(AMQTx amqtx,
java.io.DataOutput dataOut) |
Modifier and Type | Method and Description |
---|---|
void |
KahaReferenceStoreAdapter.savePreparedState(java.util.Map<TransactionId,AMQTx> map) |
Copyright © 2005-2017. All Rights Reserved.