org.apache.activemq.store.kahadaptor
public class KahaTransactionStore extends java.lang.Object implements TransactionStore, BrokerServiceAware
Modifier and Type | Method and Description |
---|---|
void |
commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable before,
java.lang.Runnable after) |
void |
delete() |
protected org.apache.activemq.store.kahadaptor.KahaTransaction |
getOrCreateTx(TransactionId key) |
protected MessageStore |
getStoreById(java.lang.Object id) |
protected org.apache.activemq.store.kahadaptor.KahaTransaction |
getTx(TransactionId key) |
void |
prepare(TransactionId txid) |
MessageStore |
proxy(MessageStore messageStore) |
TopicMessageStore |
proxy(TopicMessageStore messageStore) |
void |
recover(TransactionRecoveryListener listener) |
protected void |
removeTx(TransactionId key) |
void |
rollback(TransactionId txid) |
void |
setBrokerService(BrokerService brokerService) |
void |
start() |
void |
stop() |
public MessageStore proxy(MessageStore messageStore)
public TopicMessageStore proxy(TopicMessageStore messageStore)
public void prepare(TransactionId txid)
prepare
in interface TransactionStore
TransactionStore.prepare(TransactionId)
public void commit(TransactionId txid, boolean wasPrepared, java.lang.Runnable before, java.lang.Runnable after) throws java.io.IOException
commit
in interface TransactionStore
java.io.IOException
public void rollback(TransactionId txid)
rollback
in interface TransactionStore
TransactionStore.rollback(TransactionId)
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public void recover(TransactionRecoveryListener listener) throws java.io.IOException
recover
in interface TransactionStore
java.io.IOException
protected org.apache.activemq.store.kahadaptor.KahaTransaction getTx(TransactionId key)
protected org.apache.activemq.store.kahadaptor.KahaTransaction getOrCreateTx(TransactionId key)
protected void removeTx(TransactionId key)
public void delete()
protected MessageStore getStoreById(java.lang.Object id)
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
Copyright © 2005-2014. All Rights Reserved.