public class JdbcMemoryTransactionStore extends MemoryTransactionStore
MemoryTransactionStore.AddMessageCommand, MemoryTransactionStore.RemoveMessageCommand, MemoryTransactionStore.Tx
inflightTransactions, persistenceAdapter, preparedTransactions
Constructor and Description |
---|
JdbcMemoryTransactionStore(JDBCPersistenceAdapter jdbcPersistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(TopicMessageStore topicMessageStore,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
protected void |
onProxyQueueStore(ProxyMessageStore proxyQueueMessageStore) |
protected void |
onProxyTopicStore(ProxyTopicMessageStore proxyTopicMessageStore) |
protected void |
onRecovered(MemoryTransactionStore.Tx tx) |
void |
prepare(TransactionId txid) |
void |
recover(TransactionRecoveryListener listener) |
void |
recoverAck(long id,
byte[] xid,
byte[] message) |
void |
recoverAdd(long id,
byte[] messageBytes) |
void |
recoverLastAck(byte[] encodedXid,
ActiveMQDestination destination,
String subName,
String clientId) |
void |
rollback(TransactionId txid) |
commit, delete, getPreparedTx, getTx, proxy, proxy, start, stop
public JdbcMemoryTransactionStore(JDBCPersistenceAdapter jdbcPersistenceAdapter)
public void prepare(TransactionId txid) throws IOException
prepare
in interface TransactionStore
prepare
in class MemoryTransactionStore
IOException
TransactionStore.prepare(TransactionId)
public void rollback(TransactionId txid) throws IOException
rollback
in interface TransactionStore
rollback
in class MemoryTransactionStore
IOException
TransactionStore.rollback(TransactionId)
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
recover
in class MemoryTransactionStore
IOException
public void recoverAdd(long id, byte[] messageBytes) throws IOException
IOException
public void recoverAck(long id, byte[] xid, byte[] message) throws IOException
IOException
public void recoverLastAck(byte[] encodedXid, ActiveMQDestination destination, String subName, String clientId) throws IOException
IOException
protected void onProxyTopicStore(ProxyTopicMessageStore proxyTopicMessageStore)
onProxyTopicStore
in class MemoryTransactionStore
protected void onProxyQueueStore(ProxyMessageStore proxyQueueMessageStore)
onProxyQueueStore
in class MemoryTransactionStore
protected void onRecovered(MemoryTransactionStore.Tx tx)
onRecovered
in class MemoryTransactionStore
public void acknowledge(TopicMessageStore topicMessageStore, String clientId, String subscriptionName, MessageId messageId, MessageAck ack) throws IOException
acknowledge
in class MemoryTransactionStore
IOException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.