org.apache.activemq.store.journal

Class JournalTransactionStore

java.lang.Object

org.apache.activemq.store.journal.JournalTransactionStore

All Implemented Interfaces:

Service, TransactionStore

public class JournalTransactionStore
extends java.lang.Object
implements TransactionStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JournalTransactionStore.Tx Operations
static class	JournalTransactionStore.TxOperation

Constructor Summary

Constructors

Constructor and Description
JournalTransactionStore(JournalPersistenceAdapter adapter)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(JournalTopicMessageStore store, JournalTopicAck ack, org.apache.activeio.journal.RecordLocation location)
org.apache.activeio.journal.RecordLocation	checkpoint()
void	commit(TransactionId txid, boolean wasPrepared, java.lang.Runnable preCommit, java.lang.Runnable postCommit)
JournalTransactionStore.Tx	getTx(java.lang.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 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 JournalTransactionStore.Tx getTx(java.lang.Object txid,
                               org.apache.activeio.journal.RecordLocation 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 JournalTransactionStore.Tx 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(JournalMessageStore store,
                 MessageAck ack,
                 org.apache.activeio.journal.RecordLocation location)
                   throws java.io.IOException

Parameters:

ack -

Throws:

java.io.IOException

acknowledge

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

checkpoint

public org.apache.activeio.journal.RecordLocation checkpoint()
                                                      throws java.io.IOException

Throws:

java.io.IOException

isDoingRecover

public boolean isDoingRecover()