public class AMQTransactionStore extends Object implements TransactionStore
Modifier and Type | Field and Description |
---|---|
protected Map<TransactionId,AMQTx> |
inflightTransactions |
Constructor and Description |
---|
AMQTransactionStore(AMQPersistenceAdapter adapter) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(AMQTopicMessageStore store,
JournalTopicAck ack,
Location location) |
Location |
checkpoint() |
void |
commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
Map<TransactionId,AMQTx> |
getPreparedTransactions() |
AMQTx |
getTx(TransactionId txid,
Location location) |
boolean |
isDoingRecover() |
void |
prepare(TransactionId txid) |
void |
recover(TransactionRecoveryListener listener) |
void |
removeMessage(AMQMessageStore store,
MessageAck ack,
Location location) |
AMQTx |
replayCommit(TransactionId txid,
boolean wasPrepared) |
void |
replayPrepare(TransactionId txid) |
void |
replayRollback(TransactionId txid) |
void |
rollback(TransactionId txid) |
void |
setPreparedTransactions(Map<TransactionId,AMQTx> preparedTransactions) |
void |
start() |
void |
stop() |
protected Map<TransactionId,AMQTx> inflightTransactions
public AMQTransactionStore(AMQPersistenceAdapter adapter)
public void prepare(TransactionId txid) throws IOException
prepare
in interface TransactionStore
IOException
TransactionStore.prepare(TransactionId)
public void replayPrepare(TransactionId txid) throws IOException
IOException
TransactionStore.prepare(TransactionId)
public AMQTx getTx(TransactionId txid, Location location)
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
XAException
IOException
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
public AMQTx replayCommit(TransactionId txid, boolean wasPrepared) throws IOException
XAException
IOException
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
public void rollback(TransactionId txid) throws IOException
rollback
in interface TransactionStore
IOException
TransactionStore.rollback(TransactionId)
public void replayRollback(TransactionId txid) throws IOException
IOException
TransactionStore.rollback(TransactionId)
public void start() throws Exception
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
public void removeMessage(AMQMessageStore store, MessageAck ack, Location location) throws IOException
ack
- IOException
public void acknowledge(AMQTopicMessageStore store, JournalTopicAck ack, Location location)
public Location checkpoint() throws IOException
IOException
public boolean isDoingRecover()
public Map<TransactionId,AMQTx> getPreparedTransactions()
public void setPreparedTransactions(Map<TransactionId,AMQTx> preparedTransactions)
preparedTransactions
- the preparedTransactions to setCopyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.