public interface JDBCAdapter
Modifier and Type | Method and Description |
---|---|
void |
doAddMessage(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority) |
void |
doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageId,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef) |
void |
doCreateTables(TransactionContext c) |
void |
doDeleteOldMessages(TransactionContext c,
boolean isPrioritizedMessages) |
void |
doDeleteSubscription(TransactionContext c,
ActiveMQDestination destinationName,
java.lang.String clientId,
java.lang.String subscriptionName) |
void |
doDropTables(TransactionContext c) |
SubscriptionInfo[] |
doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination) |
java.util.Set<ActiveMQDestination> |
doGetDestinations(TransactionContext c) |
int |
doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
boolean isPrioritizeMessages) |
long |
doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.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) |
java.lang.String |
doGetMessageReference(TransactionContext c,
long id) |
SubscriptionInfo |
doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName) |
void |
doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener) |
void |
doRecover(TransactionContext c,
ActiveMQDestination destination,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
long nextSeq,
long priority,
int maxReturned,
boolean isPrioritizeMessages,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessagesWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
JDBCMessageRecoveryListener listener) |
void |
doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName) |
void |
doRemoveMessage(TransactionContext c,
long seq) |
void |
doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long prio) |
void |
doSetLastAckWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long re,
long re1) |
void |
doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo subscriptionInfo,
boolean retroactive,
boolean isPrioritizeMessages) |
int |
getMaxRows() |
long[] |
getStoreSequenceId(TransactionContext c,
ActiveMQDestination destination,
MessageId messageID) |
void |
setMaxRows(int maxRows) |
void |
setStatements(Statements statementProvider) |
void |
setUseExternalMessageReferences(boolean useExternalMessageReferences) |
void setStatements(Statements statementProvider)
void doCreateTables(TransactionContext c) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doDropTables(TransactionContext c) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, java.lang.String messageRef) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
byte[] doGetMessage(TransactionContext c, MessageId id) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
byte[] doGetMessageById(TransactionContext c, long storeSequenceId) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
java.lang.String doGetMessageReference(TransactionContext c, long id) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doRemoveMessage(TransactionContext c, long seq) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener) throws java.lang.Exception
java.lang.Exception
void doSetLastAck(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long prio) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, JDBCMessageRecoveryListener listener) throws java.lang.Exception
java.lang.Exception
void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws java.lang.Exception
java.lang.Exception
void doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws java.lang.Exception
java.lang.Exception
void doSetSubscriberEntry(TransactionContext c, SubscriptionInfo subscriptionInfo, boolean retroactive, boolean isPrioritizeMessages) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
long[] getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doDeleteSubscription(TransactionContext c, ActiveMQDestination destinationName, java.lang.String clientId, java.lang.String subscriptionName) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doDeleteOldMessages(TransactionContext c, boolean isPrioritizedMessages) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
long doGetLastMessageStoreSequenceId(TransactionContext c) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
java.util.Set<ActiveMQDestination> doGetDestinations(TransactionContext c) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void setUseExternalMessageReferences(boolean useExternalMessageReferences)
SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, boolean isPrioritizeMessages) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
int doGetMessageCount(TransactionContext c, ActiveMQDestination destination) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long nextSeq, long priority, int maxReturned, boolean isPrioritizeMessages, JDBCMessageRecoveryListener listener) throws java.lang.Exception
java.lang.Exception
long doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriberName) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
long doGetLastProducerSequenceId(TransactionContext c, ProducerId id) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
void doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long re, long re1) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
int getMaxRows()
void setMaxRows(int maxRows)
Copyright © 2005-2012. All Rights Reserved.