Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » jdbc » [javadoc | source]
org.apache.activemq.store.jdbc
public interface: JDBCAdapter [javadoc | source]

All Known Implementing Classes:
    TransactJDBCAdapter, PostgresqlJDBCAdapter, ImageBasedJDBCAdaptor, AxionJDBCAdapter, DefaultJDBCAdapter, BytesJDBCAdapter, MySqlJDBCAdapter, DB2JDBCAdapter, BlobJDBCAdapter, InformixJDBCAdapter, SybaseJDBCAdapter, HsqldbJDBCAdapter, MaxDBJDBCAdapter, OracleJDBCAdapter, StreamJDBCAdapter

Method from org.apache.activemq.store.jdbc.JDBCAdapter Summary:
doAddMessage,   doAddMessageReference,   doCreateTables,   doDeleteOldMessages,   doDeleteSubscription,   doDropTables,   doGetAllSubscriptions,   doGetDestinations,   doGetDurableSubscriberMessageCount,   doGetLastAckedDurableSubscriberMessageId,   doGetLastMessageStoreSequenceId,   doGetMessage,   doGetMessageById,   doGetMessageCount,   doGetMessageReference,   doGetSubscriberEntry,   doMessageIdScan,   doRecover,   doRecoverNextMessages,   doRecoverNextMessages,   doRecoverSubscription,   doRemoveAllMessages,   doRemoveMessage,   doSetLastAck,   doSetSubscriberEntry,   getStoreSequenceId,   setStatements,   setUseExternalMessageReferences
Method from org.apache.activemq.store.jdbc.JDBCAdapter Detail:
 public  void doAddMessage(TransactionContext c,
    long sequence,
    MessageId messageID,
    ActiveMQDestination destination,
    byte[] data,
    long expiration) throws SQLException, IOException
 public  void doAddMessageReference(TransactionContext c,
    long sequence,
    MessageId messageId,
    ActiveMQDestination destination,
    long expirationTime,
    String messageRef) throws SQLException, IOException
 public  void doCreateTables(TransactionContext c) throws SQLException, IOException
 public  void doDeleteOldMessages(TransactionContext c) throws SQLException, IOException
 public  void doDeleteSubscription(TransactionContext c,
    ActiveMQDestination destinationName,
    String clientId,
    String subscriptionName) throws SQLException, IOException
 public  void doDropTables(TransactionContext c) throws SQLException, IOException
 public SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c,
    ActiveMQDestination destination) throws SQLException, IOException
 public Set<ActiveMQDestination> doGetDestinations(TransactionContext c) throws SQLException, IOException
 public int doGetDurableSubscriberMessageCount(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriptionName) throws SQLException, IOException
 public long doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriberName) throws SQLException, IOException
 public long doGetLastMessageStoreSequenceId(TransactionContext c) throws SQLException, IOException
 public byte[] doGetMessage(TransactionContext c,
    MessageId id) throws SQLException, IOException
 public byte[] doGetMessageById(TransactionContext c,
    long storeSequenceId) throws SQLException, IOException
 public int doGetMessageCount(TransactionContext c,
    ActiveMQDestination destination) throws SQLException, IOException
 public String doGetMessageReference(TransactionContext c,
    long id) throws SQLException, IOException
 public SubscriptionInfo doGetSubscriberEntry(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriptionName) throws SQLException, IOException
 public  void doMessageIdScan(TransactionContext c,
    int limit,
    JDBCMessageIdScanListener listener) throws SQLException, IOException
 public  void doRecover(TransactionContext c,
    ActiveMQDestination destination,
    JDBCMessageRecoveryListener listener) throws Exception
 public  void doRecoverNextMessages(TransactionContext c,
    ActiveMQDestination destination,
    long nextSeq,
    int maxReturned,
    JDBCMessageRecoveryListener listener) throws Exception
 public  void doRecoverNextMessages(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriptionName,
    long seq,
    int maxReturned,
    JDBCMessageRecoveryListener listener) throws Exception
 public  void doRecoverSubscription(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriptionName,
    JDBCMessageRecoveryListener listener) throws Exception
 public  void doRemoveAllMessages(TransactionContext c,
    ActiveMQDestination destinationName) throws SQLException, IOException
 public  void doRemoveMessage(TransactionContext c,
    long seq) throws SQLException, IOException
 public  void doSetLastAck(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriptionName,
    long seq) throws SQLException, IOException
 public  void doSetSubscriberEntry(TransactionContext c,
    SubscriptionInfo subscriptionInfo,
    boolean retroactive) throws SQLException, IOException
 public long getStoreSequenceId(TransactionContext c,
    MessageId messageID) throws SQLException, IOException
 public  void setStatements(Statements statementProvider)
 public  void setUseExternalMessageReferences(boolean useExternalMessageReferences)