org.apache.activemq.store.amq
Class AMQTransactionStore

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

public class AMQTransactionStore
extends java.lang.Object
implements TransactionStore


Field Summary
protected  java.util.Map<TransactionId,AMQTx> inflightTransactions
           
 
Constructor Summary
AMQTransactionStore(AMQPersistenceAdapter adapter)
           
 
Method Summary
 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


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.