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

Packages that use TransactionContext
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
 TransactionContext JDBCPersistenceAdapter.getTransactionContext()
           
 TransactionContext JDBCPersistenceAdapter.getTransactionContext(ConnectionContext context)
           
 

Methods in org.apache.activemq.store.jdbc with parameters of type TransactionContext
 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 storeSequenceIdForMessageId)
           
 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 nextSeq, long priority, 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)
           
 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
 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 BlobJDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
           
 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 sequence)
           
 void DefaultJDBCAdapter.doCreateTables(TransactionContext c)
           
 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[] DefaultJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
           
 byte[] BlobJDBCAdapter.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 nextSeq, long priority, 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)
           
 long[] DefaultJDBCAdapter.getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)
           
 



Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.