Uses of Class
org.apache.activemq.store.jdbc.TransactionContext

Packages that use TransactionContext

Package	Description
org.apache.activemq.store.jdbc	Message persistence implemented using JDBC
org.apache.activemq.store.jdbc.adapter	Implements database/driver apapters to compensate for the wide differences in the BLOB handing of JDBC drivers.

Uses of TransactionContext in org.apache.activemq.store.jdbc

Methods in org.apache.activemq.store.jdbc that return TransactionContext

Modifier and Type	Method	Description
TransactionContext	JDBCPersistenceAdapter.getTransactionContext()
TransactionContext	JDBCPersistenceAdapter.getTransactionContext(ConnectionContext context)

Methods in org.apache.activemq.store.jdbc with parameters of type TransactionContext

Modifier and Type	Method	Description
void	JDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
void	JDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef)
void	JDBCAdapter.doClearLastAck(TransactionContext c, ActiveMQDestination destination, byte priority, String subId, String subName)
void	JDBCAdapter.doCommitAddOp(TransactionContext c, long preparedSequence, long sequence)
void	JDBCAdapter.doCreateTables(TransactionContext c)
void	JDBCAdapter.doDeleteOldMessages(TransactionContext c)
void	JDBCAdapter.doDeleteSubscription(TransactionContext c, ActiveMQDestination destinationName, String clientId, String subscriptionName)
void	JDBCAdapter.doDropTables(TransactionContext c)
SubscriptionInfo[]	JDBCAdapter.doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination)
Set<ActiveMQDestination>	JDBCAdapter.doGetDestinations(TransactionContext c)
int	JDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, boolean isPrioritizeMessages)
long	JDBCAdapter.doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName)
long	JDBCAdapter.doGetLastMessageStoreSequenceId(TransactionContext c)
long	JDBCAdapter.doGetLastProducerSequenceId(TransactionContext c, ProducerId id)
byte[]	JDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
byte[]	JDBCAdapter.doGetMessageById(TransactionContext c, long storeSequenceId)
int	JDBCAdapter.doGetMessageCount(TransactionContext c, ActiveMQDestination destination)
String	JDBCAdapter.doGetMessageReference(TransactionContext c, long id)
SubscriptionInfo	JDBCAdapter.doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName)
void	JDBCAdapter.doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener)
void	JDBCAdapter.doRecordDestination(TransactionContext c, ActiveMQDestination destination)
void	JDBCAdapter.doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener)
void	JDBCAdapter.doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long[] lastRecoveredEntries, long maxSeq, int maxReturned, boolean isPrioritizeMessages, JDBCMessageRecoveryListener listener)
void	JDBCAdapter.doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
void	JDBCAdapter.doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
void	JDBCAdapter.doRecoverPreparedOps(TransactionContext c, JdbcMemoryTransactionStore jdbcMemoryTransactionStore)
void	JDBCAdapter.doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, JDBCMessageRecoveryListener listener)
void	JDBCAdapter.doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName)
void	JDBCAdapter.doRemoveMessage(TransactionContext c, long seq, XATransactionId xid)
void	JDBCAdapter.doSetLastAck(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long seq, long prio)
void	JDBCAdapter.doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long re, long re1)
void	JDBCAdapter.doSetSubscriberEntry(TransactionContext c, SubscriptionInfo subscriptionInfo, boolean retroactive, boolean isPrioritizeMessages)
void	JDBCAdapter.doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data)
long[]	JDBCTopicMessageStore.getCachedStoreSequenceId(TransactionContext transactionContext, ActiveMQDestination destination, MessageId messageId)
long[]	JDBCAdapter.getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)

Uses of TransactionContext in org.apache.activemq.store.jdbc.adapter

Methods in org.apache.activemq.store.jdbc.adapter with parameters of type TransactionContext

Modifier and Type	Method	Description
void	BlobJDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
void	DefaultJDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)	A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
void	DefaultJDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, long expirationTime, String messageRef)
void	DefaultJDBCAdapter.doClearLastAck(TransactionContext c, ActiveMQDestination destination, byte priority, String clientId, String subName)
void	DefaultJDBCAdapter.doCommitAddOp(TransactionContext c, long preparedSequence, long sequence)
void	DefaultJDBCAdapter.doCreateTables(TransactionContext transactionContext)
void	DefaultJDBCAdapter.doDeleteOldMessages(TransactionContext c)
void	DefaultJDBCAdapter.doDeleteSubscription(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName)
void	DefaultJDBCAdapter.doDropTables(TransactionContext c)
SubscriptionInfo[]	DefaultJDBCAdapter.doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination)
Set<ActiveMQDestination>	DefaultJDBCAdapter.doGetDestinations(TransactionContext c)
int	DefaultJDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, boolean isPrioritizedMessages)
long	DefaultJDBCAdapter.doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName)
long	DefaultJDBCAdapter.doGetLastMessageStoreSequenceId(TransactionContext c)
long	DefaultJDBCAdapter.doGetLastProducerSequenceId(TransactionContext c, ProducerId id)
byte[]	BlobJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
byte[]	DefaultJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
byte[]	DefaultJDBCAdapter.doGetMessageById(TransactionContext c, long storeSequenceId)
int	DefaultJDBCAdapter.doGetMessageCount(TransactionContext c, ActiveMQDestination destination)
String	DefaultJDBCAdapter.doGetMessageReference(TransactionContext c, long seq)
SubscriptionInfo	DefaultJDBCAdapter.doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName)
void	DefaultJDBCAdapter.doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener)
void	DefaultJDBCAdapter.doRecordDestination(TransactionContext c, ActiveMQDestination destination)
void	DefaultJDBCAdapter.doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener)
void	DefaultJDBCAdapter.doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long[] lastRecoveredEntries, long maxSeq, int maxReturned, boolean isPrioritizedMessages, JDBCMessageRecoveryListener listener)
void	DefaultJDBCAdapter.doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
void	DefaultJDBCAdapter.doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
void	DefaultJDBCAdapter.doRecoverPreparedOps(TransactionContext c, JdbcMemoryTransactionStore jdbcMemoryTransactionStore)
void	DefaultJDBCAdapter.doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, JDBCMessageRecoveryListener listener)
void	DefaultJDBCAdapter.doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName)
void	DefaultJDBCAdapter.doRemoveMessage(TransactionContext c, long seq, XATransactionId xid)	A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
void	DefaultJDBCAdapter.doSetLastAck(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long seq, long priority)
void	DefaultJDBCAdapter.doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long seq, long priority)
void	DefaultJDBCAdapter.doSetSubscriberEntry(TransactionContext c, SubscriptionInfo info, boolean retroactive, boolean isPrioritizedMessages)
void	DefaultJDBCAdapter.doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data)
long[]	DefaultJDBCAdapter.getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)