org.activemq.store.journal
Class JournalTransactionStore

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

public class JournalTransactionStore
extends Object
implements TransactionStore


Nested Class Summary
static interface JournalTransactionStore.AddMessageCommand
           
static interface JournalTransactionStore.RemoveMessageCommand
           
static class JournalTransactionStore.Tx
          Operations
static class JournalTransactionStore.TxOperation
           
 
Nested classes/interfaces inherited from interface org.activemq.store.TransactionStore
TransactionStore.RecoveryListener
 
Constructor Summary
JournalTransactionStore(JournalPersistenceAdapter adapter)
           
 
Method Summary
 void acknowledge(JournalTopicMessageStore store, JournalAck ack, org.activeio.journal.RecordLocation location)
           
 org.activeio.journal.RecordLocation checkpoint()
           
 void commit(Object txid, boolean wasPrepared)
           
 JournalTransactionStore.Tx getTx(Object txid, org.activeio.journal.RecordLocation location)
           
 void prepare(Object txid)
           
 void recover(TransactionStore.RecoveryListener listener)
           
 void removeMessage(JournalMessageStore store, MessageAck ack, org.activeio.journal.RecordLocation location)
           
 JournalTransactionStore.Tx replayCommit(Object txid, boolean wasPrepared)
           
 void replayPrepare(Object txid)
           
 void replayRollback(Object txid)
           
 void rollback(Object txid)
           
 void start()
          Called to start the service
 void stop()
          Called to shutdown the service
 
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(Object txid)
             throws XAException
Specified by:
prepare in interface TransactionStore
Throws:
XAException
IOException
See Also:
org.activemq.store.TransactionStore#prepare(TransactionId)

replayPrepare

public void replayPrepare(Object txid)
                   throws IOException
Throws:
IOException
See Also:
org.activemq.store.TransactionStore#prepare(TransactionId)

getTx

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

commit

public void commit(Object txid,
                   boolean wasPrepared)
            throws XAException
Specified by:
commit in interface TransactionStore
Throws:
XAException
XAException
See Also:
org.activemq.store.TransactionStore#commit(org.activemq.service.Transaction)

replayCommit

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

rollback

public void rollback(Object txid)
              throws XAException
Specified by:
rollback in interface TransactionStore
Throws:
XAException
IOException
See Also:
org.activemq.store.TransactionStore#rollback(TransactionId)

replayRollback

public void replayRollback(Object txid)
                    throws IOException
Throws:
IOException
See Also:
org.activemq.store.TransactionStore#rollback(TransactionId)

recover

public void recover(TransactionStore.RecoveryListener listener)
             throws XAException
Specified by:
recover in interface TransactionStore
Throws:
XAException

removeMessage

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

acknowledge

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

checkpoint

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

start

public void start()
           throws JMSException
Description copied from interface: Service
Called to start the service

Specified by:
start in interface Service
Throws:
JMSException

stop

public void stop()
          throws JMSException
Description copied from interface: Service
Called to shutdown the service

Specified by:
stop in interface Service
Throws:
JMSException


Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.