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

All Implemented Interfaces:
    TransactionStore

Nested Class Summary:
public static class  JournalTransactionStore.TxOperation   
public static class  JournalTransactionStore.Tx  Operations 
Constructor:
 public JournalTransactionStore(JournalPersistenceAdapter adapter) 
Method from org.apache.activemq.store.journal.JournalTransactionStore Summary:
acknowledge,   addMessage,   checkpoint,   commit,   getTx,   isDoingRecover,   prepare,   recover,   removeMessage,   replayCommit,   replayPrepare,   replayRollback,   rollback,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.journal.JournalTransactionStore Detail:
 public  void acknowledge(JournalTopicMessageStore store,
    JournalTopicAck ack,
    RecordLocation location) 
  void addMessage(JournalMessageStore store,
    Message message,
    RecordLocation location) throws IOException 
 public RecordLocation checkpoint() throws IOException 
 public  void commit(TransactionId txid,
    boolean wasPrepared) throws IOException 
 public Tx getTx(Object txid,
    RecordLocation location) 
 public boolean isDoingRecover() 
 public  void prepare(TransactionId txid) throws IOException 
 public synchronized  void recover(TransactionRecoveryListener listener) throws IOException 
 public  void removeMessage(JournalMessageStore store,
    MessageAck ack,
    RecordLocation location) throws IOException 
 public Tx 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 start() throws Exception 
 public  void stop() throws Exception