org.apache.activemq.store.journal
Class JournalTransactionStore

java.lang.Object
  extended by org.apache.activemq.store.journal.JournalTransactionStore
All Implemented Interfaces:
Service, TransactionStore

public class JournalTransactionStore
extends Object
implements TransactionStore


Nested Class Summary
static class JournalTransactionStore.Tx
          Operations
static class JournalTransactionStore.TxOperation
           
 
Constructor Summary
JournalTransactionStore(JournalPersistenceAdapter adapter)
           
 
Method Summary
 void acknowledge(JournalTopicMessageStore store, JournalTopicAck ack, org.apache.activeio.journal.RecordLocation location)
           
 org.apache.activeio.journal.RecordLocation checkpoint()
           
 void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit)
           
 JournalTransactionStore.Tx getTx(Object txid, org.apache.activeio.journal.RecordLocation location)
           
 boolean isDoingRecover()
           
 void prepare(TransactionId txid)
           
 void recover(TransactionRecoveryListener listener)
           
 void removeMessage(JournalMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation location)
           
 JournalTransactionStore.Tx replayCommit(TransactionId txid, boolean wasPrepared)
           
 void replayPrepare(TransactionId txid)
           
 void replayRollback(TransactionId txid)
           
 void rollback(TransactionId txid)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JournalTransactionStore

public JournalTransactionStore(JournalPersistenceAdapter adapter)
Method Detail

prepare

public void prepare(TransactionId txid)
             throws IOException
Specified by:
prepare in interface TransactionStore
Throws:
IOException
See Also:
TransactionStore.prepare(TransactionId)

replayPrepare

public void replayPrepare(TransactionId txid)
                   throws IOException
Throws:
IOException
See Also:
TransactionStore.prepare(TransactionId)

getTx

public JournalTransactionStore.Tx getTx(Object txid,
                                        org.apache.activeio.journal.RecordLocation location)

commit

public void commit(TransactionId txid,
                   boolean wasPrepared,
                   Runnable preCommit,
                   Runnable postCommit)
            throws IOException
Specified by:
commit in interface TransactionStore
Throws:
XAException
IOException
See Also:
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)

replayCommit

public JournalTransactionStore.Tx replayCommit(TransactionId txid,
                                               boolean wasPrepared)
                                        throws IOException
Throws:
XAException
IOException
See Also:
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)

rollback

public void rollback(TransactionId txid)
              throws IOException
Specified by:
rollback in interface TransactionStore
Throws:
IOException
See Also:
TransactionStore.rollback(TransactionId)

replayRollback

public void replayRollback(TransactionId txid)
                    throws IOException
Throws:
IOException
See Also:
TransactionStore.rollback(TransactionId)

start

public void start()
           throws Exception
Specified by:
start in interface Service
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Throws:
Exception

recover

public void recover(TransactionRecoveryListener listener)
             throws IOException
Specified by:
recover in interface TransactionStore
Throws:
IOException

removeMessage

public void removeMessage(JournalMessageStore store,
                          MessageAck ack,
                          org.apache.activeio.journal.RecordLocation location)
                   throws IOException
Parameters:
ack -
Throws:
IOException

acknowledge

public void acknowledge(JournalTopicMessageStore store,
                        JournalTopicAck ack,
                        org.apache.activeio.journal.RecordLocation location)

checkpoint

public org.apache.activeio.journal.RecordLocation checkpoint()
                                                      throws IOException
Throws:
IOException

isDoingRecover

public boolean isDoingRecover()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.