org.apache.activemq.store.amq
Class AMQTransactionStore
java.lang.Object
org.apache.activemq.store.amq.AMQTransactionStore
- All Implemented Interfaces:
- Service, TransactionStore
public class AMQTransactionStore
- extends java.lang.Object
- implements TransactionStore
Method Summary |
void |
acknowledge(AMQTopicMessageStore store,
JournalTopicAck ack,
Location location)
|
Location |
checkpoint()
|
void |
commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
|
java.util.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(java.util.Map<TransactionId,AMQTx> preparedTransactions)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
inflightTransactions
protected java.util.Map<TransactionId,AMQTx> inflightTransactions
AMQTransactionStore
public AMQTransactionStore(AMQPersistenceAdapter adapter)
prepare
public void prepare(TransactionId txid)
throws java.io.IOException
- Specified by:
prepare
in interface TransactionStore
- Throws:
java.io.IOException
- See Also:
TransactionStore.prepare(TransactionId)
replayPrepare
public void replayPrepare(TransactionId txid)
throws java.io.IOException
- Throws:
java.io.IOException
- See Also:
TransactionStore.prepare(TransactionId)
getTx
public AMQTx getTx(TransactionId txid,
Location location)
commit
public void commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
throws java.io.IOException
- Specified by:
commit
in interface TransactionStore
- Throws:
javax.transaction.xa.XAException
java.io.IOException
- See Also:
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
replayCommit
public AMQTx replayCommit(TransactionId txid,
boolean wasPrepared)
throws java.io.IOException
- Throws:
javax.transaction.xa.XAException
java.io.IOException
- See Also:
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
rollback
public void rollback(TransactionId txid)
throws java.io.IOException
- Specified by:
rollback
in interface TransactionStore
- Throws:
java.io.IOException
- See Also:
TransactionStore.rollback(TransactionId)
replayRollback
public void replayRollback(TransactionId txid)
throws java.io.IOException
- Throws:
java.io.IOException
- See Also:
TransactionStore.rollback(TransactionId)
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Throws:
java.lang.Exception
recover
public void recover(TransactionRecoveryListener listener)
throws java.io.IOException
- Specified by:
recover
in interface TransactionStore
- Throws:
java.io.IOException
removeMessage
public void removeMessage(AMQMessageStore store,
MessageAck ack,
Location location)
throws java.io.IOException
- Parameters:
ack
-
- Throws:
java.io.IOException
acknowledge
public void acknowledge(AMQTopicMessageStore store,
JournalTopicAck ack,
Location location)
checkpoint
public Location checkpoint()
throws java.io.IOException
- Throws:
java.io.IOException
isDoingRecover
public boolean isDoingRecover()
getPreparedTransactions
public java.util.Map<TransactionId,AMQTx> getPreparedTransactions()
- Returns:
- the preparedTransactions
setPreparedTransactions
public void setPreparedTransactions(java.util.Map<TransactionId,AMQTx> preparedTransactions)
- Parameters:
preparedTransactions
- the preparedTransactions to set
Copyright © 2005-2012. All Rights Reserved.