All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type |
Method and Description |
protected static void |
close(PreparedStatement s) |
protected static void |
close(ResultSet rs) |
void |
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 |
doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
long expirationTime,
String messageRef) |
void |
doClearLastAck(TransactionContext c,
ActiveMQDestination destination,
byte priority,
String clientId,
String subName) |
void |
doCommitAddOp(TransactionContext c,
long preparedSequence,
long sequence) |
void |
doCreateTables(TransactionContext transactionContext) |
void |
doDeleteOldMessages(TransactionContext c) |
void |
doDeleteSubscription(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName) |
void |
doDropTables(TransactionContext c) |
SubscriptionInfo[] |
doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination) |
Set<ActiveMQDestination> |
doGetDestinations(TransactionContext c) |
int |
doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName,
boolean isPrioritizedMessages) |
long |
doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriberName) |
long |
doGetLastMessageStoreSequenceId(TransactionContext c) |
long |
doGetLastProducerSequenceId(TransactionContext c,
ProducerId id) |
byte[] |
doGetMessage(TransactionContext c,
MessageId id) |
byte[] |
doGetMessageById(TransactionContext c,
long storeSequenceId) |
int |
doGetMessageCount(TransactionContext c,
ActiveMQDestination destination) |
String |
doGetMessageReference(TransactionContext c,
long seq) |
SubscriptionInfo |
doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName) |
void |
doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener) |
void |
doRecordDestination(TransactionContext c,
ActiveMQDestination destination) |
void |
doRecover(TransactionContext c,
ActiveMQDestination destination,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
long[] lastRecoveredEntries,
long maxSeq,
int maxReturned,
boolean isPrioritizedMessages,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessagesWithPriority(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
doRecoverPreparedOps(TransactionContext c,
JdbcMemoryTransactionStore jdbcMemoryTransactionStore) |
void |
doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
String clientId,
String subscriptionName,
JDBCMessageRecoveryListener listener) |
void |
doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName) |
void |
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 |
doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
XATransactionId xid,
String clientId,
String subscriptionName,
long seq,
long priority) |
void |
doSetLastAckWithPriority(TransactionContext c,
ActiveMQDestination destination,
XATransactionId xid,
String clientId,
String subscriptionName,
long seq,
long priority) |
void |
doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo info,
boolean retroactive,
boolean isPrioritizedMessages) |
void |
doUpdateMessage(TransactionContext c,
ActiveMQDestination destination,
MessageId id,
byte[] data) |
static void |
dumpTables(Connection c) |
static void |
dumpTables(Connection c,
String destinationName,
String clientId,
String subscriptionName) |
protected byte[] |
getBinaryData(ResultSet rs,
int index) |
int |
getMaxRows() |
Statements |
getStatements() |
long[] |
getStoreSequenceId(TransactionContext c,
ActiveMQDestination destination,
MessageId messageID) |
boolean |
isBatchStatements() |
boolean |
isBatchStatments() |
String |
limitQuery(String query) |
static void |
printQuery(Connection c,
String query,
PrintStream out) |
static void |
printQuery(PreparedStatement s,
PrintStream out) |
void |
setBatchStatements(boolean batchStatements)
Set the number of statements to process as a single batch DB update
|
void |
setBatchStatments(boolean batchStatments)
Deprecated.
|
protected void |
setBinaryData(PreparedStatement s,
int index,
byte[] data) |
void |
setMaxRows(int maxRows)
the max value for statement maxRows, used to limit jdbc queries
|
void |
setStatements(Statements statements) |
void |
setUseExternalMessageReferences(boolean useExternalMessageReferences) |