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


Method Summary
 void doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority)
           
 void doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, java.lang.String messageRef)
           
 void doCreateTables(TransactionContext c)
           
 void doDeleteOldMessages(TransactionContext c, boolean isPrioritizedMessages)
           
 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<ActiveMQDestination> doGetDestinations(TransactionContext c)
           
 int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, boolean isPrioritizeMessages)
           
 long doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.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)
           
 java.lang.String doGetMessageReference(TransactionContext c, long id)
           
 SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.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, long priority, int maxReturned, boolean isPrioritizeMessages, JDBCMessageRecoveryListener listener)
           
 void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
           
 void doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, 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, long prio)
           
 void doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.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 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,
                  long sequence,
                  MessageId messageID,
                  ActiveMQDestination destination,
                  byte[] data,
                  long expiration,
                  byte priority)
                  throws java.sql.SQLException,
                         java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doAddMessageReference

void doAddMessageReference(TransactionContext c,
                           long sequence,
                           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,
                    MessageId id)
                    throws java.sql.SQLException,
                           java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetMessageById

byte[] doGetMessageById(TransactionContext c,
                        long storeSequenceId)
                        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,
                  long prio)
                  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,
                           long priority,
                           int maxReturned,
                           JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception
Throws:
java.lang.Exception

doRecoverNextMessagesWithPriority

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

doSetSubscriberEntry

void doSetSubscriberEntry(TransactionContext c,
                          SubscriptionInfo subscriptionInfo,
                          boolean retroactive,
                          boolean isPrioritizeMessages)
                          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

getStoreSequenceId

long[] getStoreSequenceId(TransactionContext c,
                          ActiveMQDestination destination,
                          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,
                         boolean isPrioritizedMessages)
                         throws java.sql.SQLException,
                                java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetLastMessageStoreSequenceId

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

doGetDestinations

java.util.Set<ActiveMQDestination> 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,
                                       boolean isPrioritizeMessages)
                                       throws java.sql.SQLException,
                                              java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetMessageCount

int doGetMessageCount(TransactionContext c,
                      ActiveMQDestination destination)
                      throws java.sql.SQLException,
                             java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doRecoverNextMessages

void doRecoverNextMessages(TransactionContext c,
                           ActiveMQDestination destination,
                           long nextSeq,
                           long priority,
                           int maxReturned,
                           boolean isPrioritizeMessages,
                           JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception
Throws:
java.lang.Exception

doGetLastAckedDurableSubscriberMessageId

long doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
                                              ActiveMQDestination destination,
                                              java.lang.String clientId,
                                              java.lang.String subscriberName)
                                              throws java.sql.SQLException,
                                                     java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doMessageIdScan

void doMessageIdScan(TransactionContext c,
                     int limit,
                     JDBCMessageIdScanListener listener)
                     throws java.sql.SQLException,
                            java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doGetLastProducerSequenceId

long doGetLastProducerSequenceId(TransactionContext c,
                                 ProducerId id)
                                 throws java.sql.SQLException,
                                        java.io.IOException
Throws:
java.sql.SQLException
java.io.IOException

doSetLastAckWithPriority

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

getMaxRows

int getMaxRows()

setMaxRows

void setMaxRows(int maxRows)


Copyright © 2005-2011. All Rights Reserved.