public interface  org.apache.activemq.store.jdbc.JDBCAdapter extends java.lang.Object
{
public abstract void setStatements(org.apache.activemq.store.jdbc.Statements);
public abstract void doCreateTables(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException;
public abstract void doDropTables(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException;
public abstract void doAddMessage(org.apache.activemq.store.jdbc.TransactionContext, long, org.apache.activemq.command.MessageId, org.apache.activemq.command.ActiveMQDestination, byte[], long, byte, org.apache.activemq.command.XATransactionId) throws java.sql.SQLException, java.io.IOException;
public abstract void doAddMessageReference(org.apache.activemq.store.jdbc.TransactionContext, long, org.apache.activemq.command.MessageId, org.apache.activemq.command.ActiveMQDestination, long, java.lang.String) throws java.sql.SQLException, java.io.IOException;
public abstract byte[] doGetMessage(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.MessageId) throws java.sql.SQLException, java.io.IOException;
public abstract byte[] doGetMessageById(org.apache.activemq.store.jdbc.TransactionContext, long) throws java.sql.SQLException, java.io.IOException;
public abstract java.lang.String doGetMessageReference(org.apache.activemq.store.jdbc.TransactionContext, long) throws java.sql.SQLException, java.io.IOException;
public abstract void doRemoveMessage(org.apache.activemq.store.jdbc.TransactionContext, long, org.apache.activemq.command.XATransactionId) throws java.sql.SQLException, java.io.IOException;
public abstract void doRecover(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception;
public abstract void doSetLastAck(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.XATransactionId, java.lang.String, java.lang.String, long, long) throws java.sql.SQLException, java.io.IOException;
public abstract void doRecoverSubscription(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception;
public abstract void doRecoverNextMessages(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String, long, long, int, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception;
public abstract void doRecoverNextMessagesWithPriority(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String, long, long, int, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception;
public abstract void doSetSubscriberEntry(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.SubscriptionInfo, boolean, boolean) throws java.sql.SQLException, java.io.IOException;
public abstract org.apache.activemq.command.SubscriptionInfo doGetSubscriberEntry(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String) throws java.sql.SQLException, java.io.IOException;
public abstract long[] getStoreSequenceId(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.MessageId) throws java.sql.SQLException, java.io.IOException;
public abstract void doRemoveAllMessages(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination) throws java.sql.SQLException, java.io.IOException;
public abstract void doDeleteSubscription(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String) throws java.sql.SQLException, java.io.IOException;
public abstract void doDeleteOldMessages(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException;
public abstract long doGetLastMessageStoreSequenceId(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException;
public abstract java.util.Set doGetDestinations(org.apache.activemq.store.jdbc.TransactionContext) throws java.sql.SQLException, java.io.IOException;
public abstract void setUseExternalMessageReferences(boolean);
public abstract org.apache.activemq.command.SubscriptionInfo[] doGetAllSubscriptions(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination) throws java.sql.SQLException, java.io.IOException;
public abstract int doGetDurableSubscriberMessageCount(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String, boolean) throws java.sql.SQLException, java.io.IOException;
public abstract int doGetMessageCount(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination) throws java.sql.SQLException, java.io.IOException;
public abstract void doRecoverNextMessages(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, long[], long, int, boolean, org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener) throws java.lang.Exception;
public abstract long doGetLastAckedDurableSubscriberMessageId(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, java.lang.String, java.lang.String) throws java.sql.SQLException, java.io.IOException;
public abstract void doMessageIdScan(org.apache.activemq.store.jdbc.TransactionContext, int, org.apache.activemq.store.jdbc.JDBCMessageIdScanListener) throws java.sql.SQLException, java.io.IOException;
public abstract long doGetLastProducerSequenceId(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ProducerId) throws java.sql.SQLException, java.io.IOException;
public abstract void doSetLastAckWithPriority(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.XATransactionId, java.lang.String, java.lang.String, long, long) throws java.sql.SQLException, java.io.IOException;
public abstract int getMaxRows();
public abstract void setMaxRows(int);
public abstract void doRecordDestination(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination) throws java.sql.SQLException, java.io.IOException;
public abstract void doRecoverPreparedOps(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore) throws java.sql.SQLException, java.io.IOException;
public abstract void doCommitAddOp(org.apache.activemq.store.jdbc.TransactionContext, long, long) throws java.sql.SQLException, java.io.IOException;
public abstract void doClearLastAck(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, byte, java.lang.String, java.lang.String) throws java.sql.SQLException, java.io.IOException;
public abstract void doUpdateMessage(org.apache.activemq.store.jdbc.TransactionContext, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.command.MessageId, byte[]) throws java.sql.SQLException, java.io.IOException;
public abstract java.lang.String limitQuery(java.lang.String);
}