Package org.apache.activemq.store.jdbc
Interface JDBCAdapter
-
- All Known Implementing Classes:
AxionJDBCAdapter
,BlobJDBCAdapter
,BytesJDBCAdapter
,DB2JDBCAdapter
,DefaultJDBCAdapter
,HsqldbJDBCAdapter
,ImageBasedJDBCAdaptor
,InformixJDBCAdapter
,MaxDBJDBCAdapter
,MySqlJDBCAdapter
,OracleBlobJDBCAdapter
,OracleJDBCAdapter
,PostgresqlJDBCAdapter
,SqlServerJDBCAdapter
,StreamJDBCAdapter
,SybaseJDBCAdapter
,TransactJDBCAdapter
public interface JDBCAdapter
-
-
Method Summary
-
-
-
Method Detail
-
setStatements
void setStatements(Statements statementProvider)
-
doCreateTables
void doCreateTables(TransactionContext c) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doDropTables
void doDropTables(TransactionContext c) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doAddMessage
void doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doAddMessageReference
void doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetMessage
byte[] doGetMessage(TransactionContext c, MessageId id) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetMessageById
byte[] doGetMessageById(TransactionContext c, long storeSequenceId) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetMessageReference
String doGetMessageReference(TransactionContext c, long id) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doRemoveMessage
void doRemoveMessage(TransactionContext c, long seq, XATransactionId xid) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doRecover
void doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener) throws Exception
- Throws:
Exception
-
doSetLastAck
void doSetLastAck(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long seq, long prio) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doRecoverSubscription
void doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, JDBCMessageRecoveryListener listener) throws Exception
- Throws:
Exception
-
doRecoverNextMessages
void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws Exception
- Throws:
Exception
-
doRecoverNextMessagesWithPriority
void doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws Exception
- Throws:
Exception
-
doSetSubscriberEntry
void doSetSubscriberEntry(TransactionContext c, SubscriptionInfo subscriptionInfo, boolean retroactive, boolean isPrioritizeMessages) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetSubscriberEntry
SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName) throws SQLException, IOException
- Throws:
SQLException
IOException
-
getStoreSequenceId
long[] getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doRemoveAllMessages
void doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doDeleteSubscription
void doDeleteSubscription(TransactionContext c, ActiveMQDestination destinationName, String clientId, String subscriptionName) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doDeleteOldMessages
void doDeleteOldMessages(TransactionContext c) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetLastMessageStoreSequenceId
long doGetLastMessageStoreSequenceId(TransactionContext c) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetDestinations
Set<ActiveMQDestination> doGetDestinations(TransactionContext c) throws SQLException, IOException
- Throws:
SQLException
IOException
-
setUseExternalMessageReferences
void setUseExternalMessageReferences(boolean useExternalMessageReferences)
-
doGetAllSubscriptions
SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetDurableSubscriberMessageCount
int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, boolean isPrioritizeMessages) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetMessageCount
int doGetMessageCount(TransactionContext c, ActiveMQDestination destination) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doRecoverNextMessages
void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long[] lastRecoveredEntries, long maxSeq, int maxReturned, boolean isPrioritizeMessages, JDBCMessageRecoveryListener listener) throws Exception
- Throws:
Exception
-
doGetLastAckedDurableSubscriberMessageId
long doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doMessageIdScan
void doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doGetLastProducerSequenceId
long doGetLastProducerSequenceId(TransactionContext c, ProducerId id) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doSetLastAckWithPriority
void doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long re, long re1) throws SQLException, IOException
- Throws:
SQLException
IOException
-
getMaxRows
int getMaxRows()
-
setMaxRows
void setMaxRows(int maxRows)
-
doRecordDestination
void doRecordDestination(TransactionContext c, ActiveMQDestination destination) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doRecoverPreparedOps
void doRecoverPreparedOps(TransactionContext c, JdbcMemoryTransactionStore jdbcMemoryTransactionStore) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doCommitAddOp
void doCommitAddOp(TransactionContext c, long preparedSequence, long sequence) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doClearLastAck
void doClearLastAck(TransactionContext c, ActiveMQDestination destination, byte priority, String subId, String subName) throws SQLException, IOException
- Throws:
SQLException
IOException
-
doUpdateMessage
void doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data) throws SQLException, IOException
- Throws:
SQLException
IOException
-
-