org.apache.activemq.store.jdbc

Interface JDBCAdapter

All Known Implementing Classes:

AxionJDBCAdapter, BlobJDBCAdapter, BytesJDBCAdapter, DB2JDBCAdapter, DefaultJDBCAdapter, HsqldbJDBCAdapter, ImageBasedJDBCAdaptor, InformixJDBCAdapter, MaxDBJDBCAdapter, MySqlJDBCAdapter, OracleBlobJDBCAdapter, OracleJDBCAdapter, PostgresqlJDBCAdapter, StreamJDBCAdapter, SybaseJDBCAdapter, TransactJDBCAdapter

public interface JDBCAdapter

Method Summary

Modifier and Type	Method and Description
void	doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
void	doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef)
void	doClearLastAck(TransactionContext c, ActiveMQDestination destination, byte priority, String subId, String subName)
void	doCommitAddOp(TransactionContext c, long preparedSequence, long sequence)
void	doCreateTables(TransactionContext c)
void	doDeleteOldMessages(TransactionContext c)
void	doDeleteSubscription(TransactionContext c, ActiveMQDestination destinationName, 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 isPrioritizeMessages)
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 id)
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 isPrioritizeMessages, 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)
void	doSetLastAck(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long seq, long prio)
void	doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, String clientId, String subscriptionName, long re, long re1)
void	doSetSubscriberEntry(TransactionContext c, SubscriptionInfo subscriptionInfo, boolean retroactive, boolean isPrioritizeMessages)
void	doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data)
int	getMaxRows()
long[]	getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)
String	limitQuery(String query)
void	setMaxRows(int maxRows)
void	setStatements(Statements statementProvider)
void	setUseExternalMessageReferences(boolean useExternalMessageReferences)

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

limitQuery

String limitQuery(String query)