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
 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 storeSequenceIdForMessageId)
           
 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 nextSeq, long priority, 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)
           
 int getMaxRows()
           
 long[] getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)
           
 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 nextSeq,
                           long priority,
                           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 storeSequenceIdForMessageId)
                   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


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.