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.
|
Modifier and Type | Method and Description |
---|---|
TransactionContext |
JDBCPersistenceAdapter.getTransactionContext() |
TransactionContext |
JDBCPersistenceAdapter.getTransactionContext(ConnectionContext context) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCAdapter.doAddMessage(TransactionContext c,
long sequence,
org.apache.activemq.command.MessageId messageID,
org.apache.activemq.command.ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority,
org.apache.activemq.command.XATransactionId xid) |
void |
JDBCAdapter.doAddMessageReference(TransactionContext c,
long sequence,
org.apache.activemq.command.MessageId messageId,
org.apache.activemq.command.ActiveMQDestination destination,
long expirationTime,
String messageRef) |
void |
JDBCAdapter.doClearLastAck(TransactionContext c,
org.apache.activemq.command.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,
org.apache.activemq.command.ActiveMQDestination destinationName,
String clientId,
String subscriptionName) |
void |
JDBCAdapter.doDropTables(TransactionContext c) |
org.apache.activemq.command.SubscriptionInfo[] |
JDBCAdapter.doGetAllSubscriptions(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination) |
Set<org.apache.activemq.command.ActiveMQDestination> |
JDBCAdapter.doGetDestinations(TransactionContext c) |
int |
JDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName,
boolean isPrioritizeMessages) |
long |
JDBCAdapter.doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriberName) |
long |
JDBCAdapter.doGetLastMessageStoreSequenceId(TransactionContext c) |
long |
JDBCAdapter.doGetLastProducerSequenceId(TransactionContext c,
org.apache.activemq.command.ProducerId id) |
byte[] |
JDBCAdapter.doGetMessage(TransactionContext c,
org.apache.activemq.command.MessageId id) |
byte[] |
JDBCAdapter.doGetMessageById(TransactionContext c,
long storeSequenceId) |
int |
JDBCAdapter.doGetMessageCount(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination) |
String |
JDBCAdapter.doGetMessageReference(TransactionContext c,
long id) |
org.apache.activemq.command.SubscriptionInfo |
JDBCAdapter.doGetSubscriberEntry(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName) |
void |
JDBCAdapter.doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener) |
void |
JDBCAdapter.doRecordDestination(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination) |
void |
JDBCAdapter.doRecover(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
JDBCMessageRecoveryListener listener) |
void |
JDBCAdapter.doRecoverNextMessages(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
long[] lastRecoveredEntries,
long maxSeq,
int maxReturned,
boolean isPrioritizeMessages,
JDBCMessageRecoveryListener listener) |
void |
JDBCAdapter.doRecoverNextMessages(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
JDBCAdapter.doRecoverNextMessagesWithPriority(TransactionContext c,
org.apache.activemq.command.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,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName,
JDBCMessageRecoveryListener listener) |
void |
JDBCAdapter.doRemoveAllMessages(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destinationName) |
void |
JDBCAdapter.doRemoveMessage(TransactionContext c,
long seq,
org.apache.activemq.command.XATransactionId xid) |
void |
JDBCAdapter.doSetLastAck(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.XATransactionId xid,
String clientId,
String subscriptionName,
long seq,
long prio) |
void |
JDBCAdapter.doSetLastAckWithPriority(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.XATransactionId xid,
String clientId,
String subscriptionName,
long re,
long re1) |
void |
JDBCAdapter.doSetSubscriberEntry(TransactionContext c,
org.apache.activemq.command.SubscriptionInfo subscriptionInfo,
boolean retroactive,
boolean isPrioritizeMessages) |
void |
JDBCAdapter.doUpdateMessage(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.MessageId id,
byte[] data) |
long[] |
JDBCTopicMessageStore.getCachedStoreSequenceId(TransactionContext transactionContext,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.MessageId messageId) |
long[] |
JDBCAdapter.getStoreSequenceId(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.MessageId messageID) |
Modifier and Type | Method and Description |
---|---|
void |
BlobJDBCAdapter.doAddMessage(TransactionContext c,
long sequence,
org.apache.activemq.command.MessageId messageID,
org.apache.activemq.command.ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority,
org.apache.activemq.command.XATransactionId xid) |
void |
DefaultJDBCAdapter.doAddMessage(TransactionContext c,
long sequence,
org.apache.activemq.command.MessageId messageID,
org.apache.activemq.command.ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority,
org.apache.activemq.command.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,
org.apache.activemq.command.MessageId messageID,
org.apache.activemq.command.ActiveMQDestination destination,
long expirationTime,
String messageRef) |
void |
DefaultJDBCAdapter.doClearLastAck(TransactionContext c,
org.apache.activemq.command.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,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName) |
void |
DefaultJDBCAdapter.doDropTables(TransactionContext c) |
org.apache.activemq.command.SubscriptionInfo[] |
DefaultJDBCAdapter.doGetAllSubscriptions(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination) |
Set<org.apache.activemq.command.ActiveMQDestination> |
DefaultJDBCAdapter.doGetDestinations(TransactionContext c) |
int |
DefaultJDBCAdapter.doGetDurableSubscriberMessageCount(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName,
boolean isPrioritizedMessages) |
long |
DefaultJDBCAdapter.doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriberName) |
long |
DefaultJDBCAdapter.doGetLastMessageStoreSequenceId(TransactionContext c) |
long |
DefaultJDBCAdapter.doGetLastProducerSequenceId(TransactionContext c,
org.apache.activemq.command.ProducerId id) |
byte[] |
BlobJDBCAdapter.doGetMessage(TransactionContext c,
org.apache.activemq.command.MessageId id) |
byte[] |
DefaultJDBCAdapter.doGetMessage(TransactionContext c,
org.apache.activemq.command.MessageId id) |
byte[] |
DefaultJDBCAdapter.doGetMessageById(TransactionContext c,
long storeSequenceId) |
int |
DefaultJDBCAdapter.doGetMessageCount(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination) |
String |
DefaultJDBCAdapter.doGetMessageReference(TransactionContext c,
long seq) |
org.apache.activemq.command.SubscriptionInfo |
DefaultJDBCAdapter.doGetSubscriberEntry(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName) |
void |
DefaultJDBCAdapter.doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener) |
void |
DefaultJDBCAdapter.doRecordDestination(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination) |
void |
DefaultJDBCAdapter.doRecover(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
JDBCMessageRecoveryListener listener) |
void |
DefaultJDBCAdapter.doRecoverNextMessages(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
long[] lastRecoveredEntries,
long maxSeq,
int maxReturned,
boolean isPrioritizedMessages,
JDBCMessageRecoveryListener listener) |
void |
DefaultJDBCAdapter.doRecoverNextMessages(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
DefaultJDBCAdapter.doRecoverNextMessagesWithPriority(TransactionContext c,
org.apache.activemq.command.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,
org.apache.activemq.command.ActiveMQDestination destination,
String clientId,
String subscriptionName,
JDBCMessageRecoveryListener listener) |
void |
DefaultJDBCAdapter.doRemoveAllMessages(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destinationName) |
void |
DefaultJDBCAdapter.doRemoveMessage(TransactionContext c,
long seq,
org.apache.activemq.command.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,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.XATransactionId xid,
String clientId,
String subscriptionName,
long seq,
long priority) |
void |
DefaultJDBCAdapter.doSetLastAckWithPriority(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.XATransactionId xid,
String clientId,
String subscriptionName,
long seq,
long priority) |
void |
DefaultJDBCAdapter.doSetSubscriberEntry(TransactionContext c,
org.apache.activemq.command.SubscriptionInfo info,
boolean retroactive,
boolean isPrioritizedMessages) |
void |
DefaultJDBCAdapter.doUpdateMessage(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.MessageId id,
byte[] data) |
long[] |
DefaultJDBCAdapter.getStoreSequenceId(TransactionContext c,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.MessageId messageID) |
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.