org.activemq.store.jdbc
Interface JDBCAdapter

All Known Implementing Classes:
DefaultJDBCAdapter

public interface JDBCAdapter

Version:
$Revision: 1.1 $

Nested Class Summary
static interface JDBCAdapter.MessageListResultHandler
           
 
Method Summary
 void doAddMessage(java.sql.Connection c, long seq, java.lang.String messageID, java.lang.String destinationName, byte[] data, long expiration)
           
 void doAddXid(java.sql.Connection c, ActiveMQXid xid)
           
 void doCreateTables(java.sql.Connection c)
           
 void doDeleteOldMessages(java.sql.Connection c)
           
 void doDeleteSubscription(java.sql.Connection c, java.lang.String destinationName, java.lang.String subscription)
           
 void doDropTables(java.sql.Connection c)
           
 byte[] doGetMessage(java.sql.Connection c, long seq)
           
 SubscriberEntry doGetSubscriberEntry(java.sql.Connection c, java.lang.String destinationName, java.lang.String sub)
           
 void doLoadPreparedTransactions(java.sql.Connection c, TransactionStore.RecoveryListener listener)
           
 void doRecover(java.sql.Connection c, java.lang.String destinationName, JDBCAdapter.MessageListResultHandler listener)
           
 void doRecoverSubscription(java.sql.Connection c, java.lang.String destinationName, java.lang.String sub, JDBCAdapter.MessageListResultHandler listener)
           
 void doRemoveAllMessages(java.sql.Connection c, java.lang.String destinationName)
           
 void doRemoveMessage(java.sql.Connection c, long seq)
           
 void doRemoveXid(java.sql.Connection c, ActiveMQXid xid)
           
 void doSetLastAck(java.sql.Connection c, java.lang.String destinationName, java.lang.String sub, long seq)
           
 void doSetSubscriberEntry(java.sql.Connection c, java.lang.String destinationName, java.lang.String sub, SubscriberEntry subscriberEntry)
           
 java.lang.Long getMessageSequenceId(java.sql.Connection c, java.lang.String messageID)
           
 LongSequenceGenerator getSequenceGenerator()
           
 void initSequenceGenerator(java.sql.Connection c)
           
 

Method Detail

getSequenceGenerator

public LongSequenceGenerator getSequenceGenerator()

doCreateTables

public void doCreateTables(java.sql.Connection c)
                    throws java.sql.SQLException
Throws:
java.sql.SQLException

doDropTables

public void doDropTables(java.sql.Connection c)
                  throws java.sql.SQLException
Throws:
java.sql.SQLException

initSequenceGenerator

public void initSequenceGenerator(java.sql.Connection c)

doAddMessage

public void doAddMessage(java.sql.Connection c,
                         long seq,
                         java.lang.String messageID,
                         java.lang.String destinationName,
                         byte[] data,
                         long expiration)
                  throws java.sql.SQLException,
                         javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doGetMessage

public byte[] doGetMessage(java.sql.Connection c,
                           long seq)
                    throws java.sql.SQLException
Throws:
java.sql.SQLException

doRemoveMessage

public void doRemoveMessage(java.sql.Connection c,
                            long seq)
                     throws java.sql.SQLException
Throws:
java.sql.SQLException

doRecover

public void doRecover(java.sql.Connection c,
                      java.lang.String destinationName,
                      JDBCAdapter.MessageListResultHandler listener)
               throws java.sql.SQLException,
                      javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doRemoveXid

public void doRemoveXid(java.sql.Connection c,
                        ActiveMQXid xid)
                 throws java.sql.SQLException,
                        javax.transaction.xa.XAException
Throws:
java.sql.SQLException
javax.transaction.xa.XAException

doAddXid

public void doAddXid(java.sql.Connection c,
                     ActiveMQXid xid)
              throws java.sql.SQLException,
                     javax.transaction.xa.XAException
Throws:
java.sql.SQLException
javax.transaction.xa.XAException

doLoadPreparedTransactions

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

doSetLastAck

public void doSetLastAck(java.sql.Connection c,
                         java.lang.String destinationName,
                         java.lang.String sub,
                         long seq)
                  throws java.sql.SQLException,
                         javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doRecoverSubscription

public void doRecoverSubscription(java.sql.Connection c,
                                  java.lang.String destinationName,
                                  java.lang.String sub,
                                  JDBCAdapter.MessageListResultHandler listener)
                           throws java.sql.SQLException,
                                  javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doSetSubscriberEntry

public void doSetSubscriberEntry(java.sql.Connection c,
                                 java.lang.String destinationName,
                                 java.lang.String sub,
                                 SubscriberEntry subscriberEntry)
                          throws java.sql.SQLException,
                                 javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doGetSubscriberEntry

public SubscriberEntry doGetSubscriberEntry(java.sql.Connection c,
                                            java.lang.String destinationName,
                                            java.lang.String sub)
                                     throws java.sql.SQLException,
                                            javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

getMessageSequenceId

public java.lang.Long getMessageSequenceId(java.sql.Connection c,
                                           java.lang.String messageID)
                                    throws java.sql.SQLException,
                                           javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doRemoveAllMessages

public void doRemoveAllMessages(java.sql.Connection c,
                                java.lang.String destinationName)
                         throws java.sql.SQLException,
                                javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doDeleteSubscription

public void doDeleteSubscription(java.sql.Connection c,
                                 java.lang.String destinationName,
                                 java.lang.String subscription)
                          throws java.sql.SQLException,
                                 javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException

doDeleteOldMessages

public void doDeleteOldMessages(java.sql.Connection c)
                         throws java.sql.SQLException,
                                javax.jms.JMSException
Throws:
java.sql.SQLException
javax.jms.JMSException


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