org.apache.activemq.store.jdbc
Interface JDBCAdapter

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

public interface JDBCAdapter

Version:
$Revision: 1.5 $

Method Summary
 void doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration)
           
 void doAddMessageReference(TransactionContext c, long sequence, 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<ActiveMQDestination> doGetDestinations(TransactionContext c)
           
 int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriptionName)
           
 long doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, String clientId, String subscriberName)
           
 long doGetLastMessageStoreSequenceId(TransactionContext c)
           
 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 doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener)
           
 void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long nextSeq, int maxReturned, 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, SubscriptionInfo subscriptionInfo, boolean retroactive)
           
 long getStoreSequenceId(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,
                  long sequence,
                  MessageId messageID,
                  ActiveMQDestination destination,
                  byte[] data,
                  long expiration)
                  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)
                     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,
                          SubscriptionInfo subscriptionInfo,
                          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

getStoreSequenceId

long getStoreSequenceId(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

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)
                                       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,
                           int maxReturned,
                           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


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.