org.apache.activemq.store.amq

Class AMQTransactionStore

java.lang.Object

org.apache.activemq.store.amq.AMQTransactionStore

All Implemented Interfaces:

Service, TransactionStore

public class AMQTransactionStore
extends java.lang.Object
implements TransactionStore

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<TransactionId,AMQTx>	inflightTransactions

Constructor Summary

Constructors

Constructor and Description
AMQTransactionStore(AMQPersistenceAdapter adapter)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge(AMQTopicMessageStore store, JournalTopicAck ack, Location location)
Location	checkpoint()
void	commit(TransactionId txid, boolean wasPrepared, java.lang.Runnable preCommit, java.lang.Runnable postCommit)
java.util.Map<TransactionId,AMQTx>	getPreparedTransactions()
AMQTx	getTx(TransactionId txid, Location location)
boolean	isDoingRecover()
void	prepare(TransactionId txid)
void	recover(TransactionRecoveryListener listener)
void	removeMessage(AMQMessageStore store, MessageAck ack, Location location)
AMQTx	replayCommit(TransactionId txid, boolean wasPrepared)
void	replayPrepare(TransactionId txid)
void	replayRollback(TransactionId txid)
void	rollback(TransactionId txid)
void	setPreparedTransactions(java.util.Map<TransactionId,AMQTx> preparedTransactions)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inflightTransactions

protected java.util.Map<TransactionId,AMQTx> inflightTransactions

Constructor Detail

AMQTransactionStore

public AMQTransactionStore(AMQPersistenceAdapter 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 AMQTx getTx(TransactionId txid,
          Location 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 AMQTx 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(AMQMessageStore store,
                 MessageAck ack,
                 Location location)
                   throws java.io.IOException

Parameters:

ack -

Throws:

java.io.IOException

acknowledge

public void acknowledge(AMQTopicMessageStore store,
               JournalTopicAck ack,
               Location location)

checkpoint

public Location checkpoint()
                    throws java.io.IOException

Throws:

java.io.IOException

isDoingRecover

public boolean isDoingRecover()

getPreparedTransactions

public java.util.Map<TransactionId,AMQTx> getPreparedTransactions()

Returns:

the preparedTransactions

setPreparedTransactions

public void setPreparedTransactions(java.util.Map<TransactionId,AMQTx> preparedTransactions)

Parameters:

preparedTransactions - the preparedTransactions to set