org.activemq.store.journal
Class JournalTransactionStore
java.lang.Object
org.activemq.store.journal.JournalTransactionStore
- All Implemented Interfaces:
- Service, TransactionStore
public class JournalTransactionStore
- extends Object
- implements TransactionStore
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JournalTransactionStore
public JournalTransactionStore(JournalPersistenceAdapter adapter)
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-2010 Protique, Ltd.. All Rights Reserved.