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, java.lang.String messageRef)
           
 void doCreateTables(TransactionContext c)
           
 void doDeleteOldMessages(TransactionContext c)
           
 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 doGetDestinations(TransactionContext c)
           
 int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName)
           
 long doGetLastMessageBrokerSequenceId(TransactionContext c)
           
 byte[] doGetMessage(TransactionContext c, long seq)
           
 java.lang.String doGetMessageReference(TransactionContext c, long id)
           
 void doGetNextDurableSubscriberMessageIdStatement(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriberName, long id, JDBCMessageRecoveryListener listener)
           
 void doGetPrevDurableSubscriberMessageIdStatement(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriberName, long id, JDBCMessageRecoveryListener listener)
           
 SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName)
           
 void doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener)
           
 void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, 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)
           
 void doSetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, java.lang.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 java.sql.SQLException,
                           java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doDropTables

void doDropTables(TransactionContext c)
                  throws java.sql.SQLException,
                         java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doAddMessage

void doAddMessage(TransactionContext c,
                  MessageId messageID,
                  ActiveMQDestination destination,
                  byte[] data,
                  long expiration)
                  throws java.sql.SQLException,
                         java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doAddMessageReference

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

doGetMessage

byte[] doGetMessage(TransactionContext c,
                    long seq)
                    throws java.sql.SQLException,
                           java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetMessageReference

java.lang.String doGetMessageReference(TransactionContext c,
                                       long id)
                                       throws java.sql.SQLException,
                                              java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doRemoveMessage

void doRemoveMessage(TransactionContext c,
                     long seq)
                     throws java.sql.SQLException,
                            java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doRecover

void doRecover(TransactionContext c,
               ActiveMQDestination destination,
               JDBCMessageRecoveryListener listener)
               throws java.lang.Exception
Throws:
java.lang.Exception

doSetLastAck

void doSetLastAck(TransactionContext c,
                  ActiveMQDestination destination,
                  java.lang.String clientId,
                  java.lang.String subscriptionName,
                  long seq)
                  throws java.sql.SQLException,
                         java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doRecoverSubscription

void doRecoverSubscription(TransactionContext c,
                           ActiveMQDestination destination,
                           java.lang.String clientId,
                           java.lang.String subscriptionName,
                           JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception
Throws:
java.lang.Exception

doRecoverNextMessages

void doRecoverNextMessages(TransactionContext c,
                           ActiveMQDestination destination,
                           java.lang.String clientId,
                           java.lang.String subscriptionName,
                           long seq,
                           int maxReturned,
                           JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception
Throws:
java.lang.Exception

doSetSubscriberEntry

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

doGetSubscriberEntry

SubscriptionInfo doGetSubscriberEntry(TransactionContext c,
                                      ActiveMQDestination destination,
                                      java.lang.String clientId,
                                      java.lang.String subscriptionName)
                                      throws java.sql.SQLException,
                                             java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

getBrokerSequenceId

long getBrokerSequenceId(TransactionContext c,
                         MessageId messageID)
                         throws java.sql.SQLException,
                                java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doRemoveAllMessages

void doRemoveAllMessages(TransactionContext c,
                         ActiveMQDestination destinationName)
                         throws java.sql.SQLException,
                                java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doDeleteSubscription

void doDeleteSubscription(TransactionContext c,
                          ActiveMQDestination destinationName,
                          java.lang.String clientId,
                          java.lang.String subscriptionName)
                          throws java.sql.SQLException,
                                 java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doDeleteOldMessages

void doDeleteOldMessages(TransactionContext c)
                         throws java.sql.SQLException,
                                java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetLastMessageBrokerSequenceId

long doGetLastMessageBrokerSequenceId(TransactionContext c)
                                      throws java.sql.SQLException,
                                             java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetDestinations

java.util.Set doGetDestinations(TransactionContext c)
                                throws java.sql.SQLException,
                                       java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

setUseExternalMessageReferences

void setUseExternalMessageReferences(boolean useExternalMessageReferences)

doGetAllSubscriptions

SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c,
                                         ActiveMQDestination destination)
                                         throws java.sql.SQLException,
                                                java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetDurableSubscriberMessageCount

int doGetDurableSubscriberMessageCount(TransactionContext c,
                                       ActiveMQDestination destination,
                                       java.lang.String clientId,
                                       java.lang.String subscriptionName)
                                       throws java.sql.SQLException,
                                              java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetPrevDurableSubscriberMessageIdStatement

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

doGetNextDurableSubscriberMessageIdStatement

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


Copyright © 2009 Apache Software Foundation. All Rights Reserved.