public interface JDBCAdapter
void setStatements(Statements statementProvider)
void doCreateTables(TransactionContext c) throws SQLException, IOException
SQLException
IOException
void doDropTables(TransactionContext c) throws SQLException, IOException
SQLException
IOException
void doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid) throws SQLException, IOException
SQLException
IOException
void doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef) throws SQLException, IOException
SQLException
IOException
byte[] doGetMessage(TransactionContext c, MessageId id) throws SQLException, IOException
SQLException
IOException
byte[] doGetMessageById(TransactionContext c, long storeSequenceId) throws SQLException, IOException
SQLException
IOException
String doGetMessageReference(TransactionContext c, long id) throws SQLException, IOException
SQLException
IOException
void doRemoveMessage(TransactionContext c, long seq, XATransactionId xid) throws SQLException, IOException
SQLException
IOException
void doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener) throws Exception
Exception
void doSetLastAck(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long seq, long prio) throws SQLException, IOException
SQLException
IOException
void doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, JDBCMessageRecoveryListener listener) throws Exception
Exception
void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws Exception
Exception
void doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws Exception
Exception
void doSetSubscriberEntry(TransactionContext c, SubscriptionInfo subscriptionInfo, boolean retroactive, boolean isPrioritizeMessages) throws SQLException, IOException
SQLException
IOException
SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName) throws SQLException, IOException
SQLException
IOException
long[] getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID) throws SQLException, IOException
SQLException
IOException
void doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName) throws SQLException, IOException
SQLException
IOException
void doDeleteSubscription(TransactionContext c, ActiveMQDestination destinationName, String clientId, String subscriptionName) throws SQLException, IOException
SQLException
IOException
void doDeleteOldMessages(TransactionContext c) throws SQLException, IOException
SQLException
IOException
long doGetLastMessageStoreSequenceId(TransactionContext c) throws SQLException, IOException
SQLException
IOException
Set<ActiveMQDestination> doGetDestinations(TransactionContext c) throws SQLException, IOException
SQLException
IOException
void setUseExternalMessageReferences(boolean useExternalMessageReferences)
SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination) throws SQLException, IOException
SQLException
IOException
int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, boolean isPrioritizeMessages) throws SQLException, IOException
SQLException
IOException
int doGetMessageCount(TransactionContext c, ActiveMQDestination destination) throws SQLException, IOException
SQLException
IOException
void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long[] lastRecoveredEntries, long maxSeq, int maxReturned, boolean isPrioritizeMessages, JDBCMessageRecoveryListener listener) throws Exception
Exception
long doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName) throws SQLException, IOException
SQLException
IOException
void doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener) throws SQLException, IOException
SQLException
IOException
long doGetLastProducerSequenceId(TransactionContext c, ProducerId id) throws SQLException, IOException
SQLException
IOException
void doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long re, long re1) throws SQLException, IOException
SQLException
IOException
int getMaxRows()
void setMaxRows(int maxRows)
void doRecordDestination(TransactionContext c, ActiveMQDestination destination) throws SQLException, IOException
SQLException
IOException
void doRecoverPreparedOps(TransactionContext c, JdbcMemoryTransactionStore jdbcMemoryTransactionStore) throws SQLException, IOException
SQLException
IOException
void doCommitAddOp(TransactionContext c, long preparedSequence, long sequence) throws SQLException, IOException
SQLException
IOException
void doClearLastAck(TransactionContext c, ActiveMQDestination destination, byte priority, String subId, String subName) throws SQLException, IOException
SQLException
IOException
void doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data) throws SQLException, IOException
SQLException
IOException
String limitQuery(String query)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.