|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
void |
JDBCAdapter.doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageId,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
void |
JDBCAdapter.doCreateTables(TransactionContext c)
|
void |
JDBCAdapter.doDeleteOldMessages(TransactionContext c,
boolean isPrioritizedMessages)
|
void |
JDBCAdapter.doDeleteSubscription(TransactionContext c,
ActiveMQDestination destinationName,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
JDBCAdapter.doDropTables(TransactionContext c)
|
SubscriptionInfo[] |
JDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination)
|
java.util.Set<ActiveMQDestination> |
JDBCAdapter.doGetDestinations(TransactionContext c)
|
int |
JDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
boolean isPrioritizeMessages)
|
long |
JDBCAdapter.doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.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)
|
java.lang.String |
JDBCAdapter.doGetMessageReference(TransactionContext c,
long id)
|
SubscriptionInfo |
JDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
JDBCAdapter.doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener)
|
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,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doRecoverNextMessagesWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
JDBCMessageRecoveryListener listener)
|
void |
JDBCAdapter.doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName)
|
void |
JDBCAdapter.doRemoveMessage(TransactionContext c,
long seq)
|
void |
JDBCAdapter.doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long prio)
|
void |
JDBCAdapter.doSetLastAckWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long re,
long re1)
|
void |
JDBCAdapter.doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo subscriptionInfo,
boolean retroactive,
boolean isPrioritizeMessages)
|
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)
|
void |
DefaultJDBCAdapter.doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
void |
DefaultJDBCAdapter.doCreateTables(TransactionContext c)
|
void |
DefaultJDBCAdapter.doDeleteOldMessages(TransactionContext c,
boolean isPrioritizedMessages)
|
void |
DefaultJDBCAdapter.doDeleteSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
DefaultJDBCAdapter.doDropTables(TransactionContext c)
|
SubscriptionInfo[] |
DefaultJDBCAdapter.doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination)
|
java.util.Set<ActiveMQDestination> |
DefaultJDBCAdapter.doGetDestinations(TransactionContext c)
|
int |
DefaultJDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
boolean isPrioritizedMessages)
|
long |
DefaultJDBCAdapter.doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName)
|
long |
DefaultJDBCAdapter.doGetLastMessageStoreSequenceId(TransactionContext c)
|
long |
DefaultJDBCAdapter.doGetLastProducerSequenceId(TransactionContext c,
ProducerId id)
|
byte[] |
BlobJDBCAdapter.doGetMessage(TransactionContext c,
long seq)
|
byte[] |
DefaultJDBCAdapter.doGetMessage(TransactionContext c,
MessageId id)
|
byte[] |
DefaultJDBCAdapter.doGetMessageById(TransactionContext c,
long storeSequenceId)
|
int |
DefaultJDBCAdapter.doGetMessageCount(TransactionContext c,
ActiveMQDestination destination)
|
java.lang.String |
DefaultJDBCAdapter.doGetMessageReference(TransactionContext c,
long seq)
|
byte[] |
DefaultJDBCAdapter.doGetNextDurableSubscriberMessageStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName)
|
SubscriptionInfo |
DefaultJDBCAdapter.doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
DefaultJDBCAdapter.doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener)
|
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,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener)
|
void |
DefaultJDBCAdapter.doRecoverNextMessagesWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener)
|
void |
DefaultJDBCAdapter.doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
JDBCMessageRecoveryListener listener)
|
void |
DefaultJDBCAdapter.doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName)
|
void |
DefaultJDBCAdapter.doRemoveMessage(TransactionContext c,
long seq)
|
void |
DefaultJDBCAdapter.doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority)
|
void |
DefaultJDBCAdapter.doSetLastAckWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long prio)
|
void |
DefaultJDBCAdapter.doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo info,
boolean retroactive,
boolean isPrioritizedMessages)
|
long[] |
DefaultJDBCAdapter.getStoreSequenceId(TransactionContext c,
ActiveMQDestination destination,
MessageId messageID)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |