public class MemoryTransactionStore extends Object implements TransactionStore
Modifier and Type | Class and Description |
---|---|
static interface |
MemoryTransactionStore.AddMessageCommand |
static interface |
MemoryTransactionStore.RemoveMessageCommand |
class |
MemoryTransactionStore.Tx |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Object,MemoryTransactionStore.Tx> |
inflightTransactions |
protected PersistenceAdapter |
persistenceAdapter |
protected Map<TransactionId,MemoryTransactionStore.Tx> |
preparedTransactions |
Constructor and Description |
---|
MemoryTransactionStore(PersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(TopicMessageStore destination,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
delete() |
MemoryTransactionStore.Tx |
getPreparedTx(TransactionId txid) |
MemoryTransactionStore.Tx |
getTx(Object txid) |
protected void |
onProxyQueueStore(ProxyMessageStore proxyMessageStore) |
protected void |
onProxyTopicStore(ProxyTopicMessageStore proxyTopicMessageStore) |
protected void |
onRecovered(MemoryTransactionStore.Tx tx) |
void |
prepare(TransactionId txid) |
MessageStore |
proxy(MessageStore messageStore) |
TopicMessageStore |
proxy(TopicMessageStore messageStore) |
void |
recover(TransactionRecoveryListener listener) |
void |
rollback(TransactionId txid) |
void |
start() |
void |
stop() |
protected ConcurrentMap<Object,MemoryTransactionStore.Tx> inflightTransactions
protected Map<TransactionId,MemoryTransactionStore.Tx> preparedTransactions
protected final PersistenceAdapter persistenceAdapter
public MemoryTransactionStore(PersistenceAdapter persistenceAdapter)
public MessageStore proxy(MessageStore messageStore)
protected void onProxyQueueStore(ProxyMessageStore proxyMessageStore)
public TopicMessageStore proxy(TopicMessageStore messageStore)
protected void onProxyTopicStore(ProxyTopicMessageStore proxyTopicMessageStore)
public void prepare(TransactionId txid) throws IOException
prepare
in interface TransactionStore
IOException
TransactionStore.prepare(TransactionId)
public MemoryTransactionStore.Tx getTx(Object txid)
public MemoryTransactionStore.Tx getPreparedTx(TransactionId txid)
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
IOException
public void rollback(TransactionId txid) throws IOException
rollback
in interface TransactionStore
IOException
TransactionStore.rollback(TransactionId)
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
protected void onRecovered(MemoryTransactionStore.Tx tx)
public void acknowledge(TopicMessageStore destination, String clientId, String subscriptionName, MessageId messageId, MessageAck ack) throws IOException
IOException
public void delete()
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.