public class KahaTransactionStore extends Object implements TransactionStore, BrokerServiceAware
Modifier and Type | Method and Description |
---|---|
void |
commit(TransactionId txid,
boolean wasPrepared,
Runnable before,
Runnable after) |
void |
delete() |
protected org.apache.activemq.store.kahadaptor.KahaTransaction |
getOrCreateTx(TransactionId key) |
protected MessageStore |
getStoreById(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, Runnable before, Runnable after) throws IOException
commit
in interface TransactionStore
IOException
public void rollback(TransactionId txid)
rollback
in interface TransactionStore
TransactionStore.rollback(TransactionId)
public void start() throws Exception
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
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(Object id)
public void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.