org.apache.activemq.store.jdbc
Interface JDBCAdapter

All Known Implementing Classes:
AxionJDBCAdapter, BlobJDBCAdapter, BytesJDBCAdapter, DB2JDBCAdapter, DefaultJDBCAdapter, HsqldbJDBCAdapter, ImageBasedJDBCAdaptor, InformixJDBCAdapter, MaxDBJDBCAdapter, MySqlJDBCAdapter, OracleJDBCAdapter, PostgresqlJDBCAdapter, StreamJDBCAdapter

public interface JDBCAdapter

Version:
$Revision: 1.5 $

Method Summary
 void doAddMessage(TransactionContext c, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration)
           
 void doAddMessageReference(TransactionContext c, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef)
           
 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 doGetDestinations(TransactionContext c)
           
 int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName)
           
 long doGetLastMessageBrokerSequenceId(TransactionContext c)
           
 byte[] doGetMessage(TransactionContext c, long seq)
           
 String doGetMessageReference(TransactionContext c, long id)
           
 void doGetNextDurableSubscriberMessageIdStatement(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName, long id, JDBCMessageRecoveryListener listener)
           
 void doGetPrevDurableSubscriberMessageIdStatement(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName, long id, JDBCMessageRecoveryListener listener)
           
 SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName)
           
 void doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener)
           
 void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq, int maxReturned, JDBCMessageRecoveryListener listener)
           
 void doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, JDBCMessageRecoveryListener listener)
           
 void doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName)
           
 void doRemoveMessage(TransactionContext c, long seq)
           
 void doSetLastAck(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, long seq)
           
 void doSetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName, String selector, boolean retroactive)
           
 long getBrokerSequenceId(TransactionContext c, MessageId messageID)
           
 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,
                  MessageId messageID,
                  ActiveMQDestination destination,
                  byte[] data,
                  long expiration)
                  throws SQLException,
                         IOException
Throws:
SQLException
IOException

doAddMessageReference

void doAddMessageReference(TransactionContext c,
                           MessageId messageId,
                           ActiveMQDestination destination,
                           long expirationTime,
                           String messageRef)
                           throws SQLException,
                                  IOException
Throws:
SQLException
IOException

doGetMessage

byte[] doGetMessage(TransactionContext c,
                    long seq)
                    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)
                     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,
                  String clientId,
                  String subscriptionName,
                  long seq)
                  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,
                           int maxReturned,
                           JDBCMessageRecoveryListener listener)
                           throws Exception
Throws:
Exception

doSetSubscriberEntry

void doSetSubscriberEntry(TransactionContext c,
                          ActiveMQDestination destination,
                          String clientId,
                          String subscriptionName,
                          String selector,
                          boolean retroactive)
                          throws SQLException,
                                 IOException
Throws:
SQLException
IOException

doGetSubscriberEntry

SubscriptionInfo doGetSubscriberEntry(TransactionContext c,
                                      ActiveMQDestination destination,
                                      String clientId,
                                      String subscriptionName)
                                      throws SQLException,
                                             IOException
Throws:
SQLException
IOException

getBrokerSequenceId

long getBrokerSequenceId(TransactionContext c,
                         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

doGetLastMessageBrokerSequenceId

long doGetLastMessageBrokerSequenceId(TransactionContext c)
                                      throws SQLException,
                                             IOException
Throws:
SQLException
IOException

doGetDestinations

Set 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)
                                       throws SQLException,
                                              IOException
Throws:
SQLException
IOException

doGetPrevDurableSubscriberMessageIdStatement

void doGetPrevDurableSubscriberMessageIdStatement(TransactionContext c,
                                                  ActiveMQDestination destination,
                                                  String clientId,
                                                  String subscriberName,
                                                  long id,
                                                  JDBCMessageRecoveryListener listener)
                                                  throws Exception
Throws:
Exception

doGetNextDurableSubscriberMessageIdStatement

void doGetNextDurableSubscriberMessageIdStatement(TransactionContext c,
                                                  ActiveMQDestination destination,
                                                  String clientId,
                                                  String subscriberName,
                                                  long id,
                                                  JDBCMessageRecoveryListener listener)
                                                  throws Exception
Throws:
Exception


Copyright © 2011 Apache Software Foundation. All Rights Reserved.