org.activemq.store.jdbc
Interface JDBCAdapter

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

public interface JDBCAdapter

Version:
$Revision: 1.1 $

Nested Class Summary
static interface JDBCAdapter.ExpiredMessageResultHandler
           
static interface JDBCAdapter.MessageListResultHandler
           
 
Method Summary
 void doAddMessage(Connection c, long seq, String messageID, String destinationName, byte[] data, long expiration)
           
 void doAddXid(Connection c, ActiveMQXid xid)
           
 void doCreateTables(Connection c)
           
 void doDeleteExpiredMessage(Connection c, MessageIdentity messageIdentity)
           
 void doDeleteOldMessages(Connection c)
           
 void doDeleteSubscription(Connection c, String destinationName, String subscription)
           
 void doDropTables(Connection c)
           
 void doGetExpiredMessages(Connection c, JDBCAdapter.ExpiredMessageResultHandler handler)
           
 byte[] doGetMessage(Connection c, long seq)
           
 void doGetMessageForUpdate(Connection c, long seq, boolean useLocking, JDBCAdapter.ExpiredMessageResultHandler handler)
           
 SubscriberEntry doGetSubscriberEntry(Connection c, String destinationName, String sub)
           
 void doLoadPreparedTransactions(Connection c, TransactionStore.RecoveryListener listener)
           
 void doRecover(Connection c, String destinationName, JDBCAdapter.MessageListResultHandler listener)
           
 void doRecoverSubscription(Connection c, String destinationName, String sub, JDBCAdapter.MessageListResultHandler listener)
           
 void doRemoveAllMessages(Connection c, String destinationName)
           
 void doRemoveMessage(Connection c, long seq)
           
 void doRemoveXid(Connection c, ActiveMQXid xid)
           
 void doSetDeadLetterFlag(Connection c, long seq)
           
 void doSetLastAck(Connection c, String destinationName, String sub, long seq)
           
 void doSetSubscriberEntry(Connection c, String destinationName, String sub, SubscriberEntry subscriberEntry)
           
 Long getMessageSequenceId(Connection c, String messageID)
           
 LongSequenceGenerator getSequenceGenerator()
           
 StatementProvider getStatementProvider()
           
 void initSequenceGenerator(Connection c)
           
 

Method Detail

getSequenceGenerator

LongSequenceGenerator getSequenceGenerator()

doCreateTables

void doCreateTables(Connection c)
                    throws SQLException
Throws:
SQLException

doDropTables

void doDropTables(Connection c)
                  throws SQLException
Throws:
SQLException

initSequenceGenerator

void initSequenceGenerator(Connection c)

doAddMessage

void doAddMessage(Connection c,
                  long seq,
                  String messageID,
                  String destinationName,
                  byte[] data,
                  long expiration)
                  throws SQLException,
                         JMSException
Throws:
SQLException
JMSException

doGetMessage

byte[] doGetMessage(Connection c,
                    long seq)
                    throws SQLException
Throws:
SQLException

doGetMessageForUpdate

void doGetMessageForUpdate(Connection c,
                           long seq,
                           boolean useLocking,
                           JDBCAdapter.ExpiredMessageResultHandler handler)
                           throws SQLException,
                                  JMSException
Throws:
SQLException
JMSException

doRemoveMessage

void doRemoveMessage(Connection c,
                     long seq)
                     throws SQLException
Throws:
SQLException

doRecover

void doRecover(Connection c,
               String destinationName,
               JDBCAdapter.MessageListResultHandler listener)
               throws SQLException,
                      JMSException
Throws:
SQLException
JMSException

doRemoveXid

void doRemoveXid(Connection c,
                 ActiveMQXid xid)
                 throws SQLException,
                        XAException
Throws:
SQLException
XAException

doAddXid

void doAddXid(Connection c,
              ActiveMQXid xid)
              throws SQLException,
                     XAException
Throws:
SQLException
XAException

doLoadPreparedTransactions

void doLoadPreparedTransactions(Connection c,
                                TransactionStore.RecoveryListener listener)
                                throws SQLException
Throws:
SQLException

doSetLastAck

void doSetLastAck(Connection c,
                  String destinationName,
                  String sub,
                  long seq)
                  throws SQLException,
                         JMSException
Throws:
SQLException
JMSException

doRecoverSubscription

void doRecoverSubscription(Connection c,
                           String destinationName,
                           String sub,
                           JDBCAdapter.MessageListResultHandler listener)
                           throws SQLException,
                                  JMSException
Throws:
SQLException
JMSException

doSetSubscriberEntry

void doSetSubscriberEntry(Connection c,
                          String destinationName,
                          String sub,
                          SubscriberEntry subscriberEntry)
                          throws SQLException,
                                 JMSException
Throws:
SQLException
JMSException

doGetSubscriberEntry

SubscriberEntry doGetSubscriberEntry(Connection c,
                                     String destinationName,
                                     String sub)
                                     throws SQLException,
                                            JMSException
Throws:
SQLException
JMSException

getMessageSequenceId

Long getMessageSequenceId(Connection c,
                          String messageID)
                          throws SQLException,
                                 JMSException
Throws:
SQLException
JMSException

doRemoveAllMessages

void doRemoveAllMessages(Connection c,
                         String destinationName)
                         throws SQLException,
                                JMSException
Throws:
SQLException
JMSException

doDeleteSubscription

void doDeleteSubscription(Connection c,
                          String destinationName,
                          String subscription)
                          throws SQLException,
                                 JMSException
Throws:
SQLException
JMSException

doDeleteOldMessages

void doDeleteOldMessages(Connection c)
                         throws SQLException,
                                JMSException
Throws:
SQLException
JMSException

doGetExpiredMessages

void doGetExpiredMessages(Connection c,
                          JDBCAdapter.ExpiredMessageResultHandler handler)
                          throws SQLException,
                                 JMSException
Throws:
SQLException
JMSException

doDeleteExpiredMessage

void doDeleteExpiredMessage(Connection c,
                            MessageIdentity messageIdentity)
                            throws SQLException,
                                   JMSException
Throws:
SQLException
JMSException

doSetDeadLetterFlag

void doSetDeadLetterFlag(Connection c,
                         long seq)
                         throws SQLException,
                                JMSException
Throws:
SQLException
JMSException

getStatementProvider

StatementProvider getStatementProvider()


Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.