org.apache.activemq.store.kahadaptor
Class KahaTransactionStore
java.lang.Object
org.apache.activemq.store.kahadaptor.KahaTransactionStore
- All Implemented Interfaces:
- BrokerServiceAware, Service, TransactionStore
public class KahaTransactionStore
- extends Object
- implements TransactionStore, BrokerServiceAware
Provides a TransactionStore implementation that can create transaction aware
MessageStore objects from non transaction aware MessageStore objects.
- Version:
- $Revision: 1.4 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
proxy
public MessageStore proxy(MessageStore messageStore)
proxy
public TopicMessageStore proxy(TopicMessageStore messageStore)
prepare
public void prepare(TransactionId txid)
- Specified by:
prepare
in interface TransactionStore
- See Also:
TransactionStore.prepare(TransactionId)
commit
public void commit(TransactionId txid,
boolean wasPrepared)
throws IOException
- Specified by:
commit
in interface TransactionStore
- Throws:
XAException
IOException
- See Also:
org.apache.activemq.store.TransactionStore#commit(org.apache.activemq.service.Transaction)
rollback
public void rollback(TransactionId txid)
- Specified by:
rollback
in interface TransactionStore
- See Also:
TransactionStore.rollback(TransactionId)
start
public void start()
throws Exception
- Specified by:
start
in interface Service
- Throws:
Exception
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Throws:
Exception
recover
public void recover(TransactionRecoveryListener listener)
throws IOException
- Specified by:
recover
in interface TransactionStore
- Throws:
IOException
getTx
protected org.apache.activemq.store.kahadaptor.KahaTransaction getTx(TransactionId key)
getOrCreateTx
protected org.apache.activemq.store.kahadaptor.KahaTransaction getOrCreateTx(TransactionId key)
removeTx
protected void removeTx(TransactionId key)
delete
public void delete()
getStoreById
protected MessageStore getStoreById(Object id)
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interface BrokerServiceAware
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.