Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » amq » [javadoc | source]
org.apache.activemq.store.amq
public class: AMQTransactionStore [javadoc | source]
java.lang.Object
   org.apache.activemq.store.amq.AMQTransactionStore

All Implemented Interfaces:
    TransactionStore

Field Summary
protected  Map<TransactionId, AMQTx> inflightTransactions     
 Map<TransactionId, AMQTx> preparedTransactions     
Constructor:
 public AMQTransactionStore(AMQPersistenceAdapter adapter) 
Method from org.apache.activemq.store.amq.AMQTransactionStore Summary:
acknowledge,   addMessage,   checkpoint,   commit,   getPreparedTransactions,   getTx,   isDoingRecover,   prepare,   recover,   removeMessage,   replayCommit,   replayPrepare,   replayRollback,   rollback,   setPreparedTransactions,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.amq.AMQTransactionStore Detail:
 public  void acknowledge(AMQTopicMessageStore store,
    JournalTopicAck ack,
    Location location) 
  void addMessage(AMQMessageStore store,
    Message message,
    Location location) throws IOException 
 public Location checkpoint() throws IOException 
 public  void commit(TransactionId txid,
    boolean wasPrepared) throws IOException 
 public Map<TransactionId, AMQTx> getPreparedTransactions() 
 public AMQTx getTx(TransactionId txid,
    Location location) 
 public boolean isDoingRecover() 
 public  void prepare(TransactionId txid) throws IOException 
 public synchronized  void recover(TransactionRecoveryListener listener) throws IOException 
 public  void removeMessage(AMQMessageStore store,
    MessageAck ack,
    Location location) throws IOException 
 public AMQTx replayCommit(TransactionId txid,
    boolean wasPrepared) throws IOException 
 public  void replayPrepare(TransactionId txid) throws IOException 
 public  void replayRollback(TransactionId txid) throws IOException 
 public  void rollback(TransactionId txid) throws IOException 
 public  void setPreparedTransactions(Map<TransactionId, AMQTx> preparedTransactions) 
 public  void start() throws Exception 
 public  void stop() throws Exception