org.apache.activemq.store.kahadb
Class KahaDBTransactionStore
java.lang.Object
org.apache.activemq.store.kahadb.KahaDBTransactionStore
- All Implemented Interfaces:
- Service, TransactionStore
public class KahaDBTransactionStore
- extends java.lang.Object
- implements TransactionStore
Provides a TransactionStore implementation that can create transaction aware
MessageStore objects from non transaction aware MessageStore objects.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
KahaDBTransactionStore
public KahaDBTransactionStore(KahaDBStore theStore)
proxy
public MessageStore proxy(MessageStore messageStore)
proxy
public TopicMessageStore proxy(TopicMessageStore messageStore)
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)
getTx
public KahaDBTransactionStore.Tx getTx(java.lang.Object txid)
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:
java.io.IOException
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)
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
Copyright © 2005-2011. All Rights Reserved.