Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » jdbc » adapter » [javadoc | source]
org.apache.activemq.store.jdbc.adapter
public class: DefaultJDBCAdapter [javadoc | source]
java.lang.Object
   org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter

All Implemented Interfaces:
    JDBCAdapter

Direct Known Subclasses:
    TransactJDBCAdapter, PostgresqlJDBCAdapter, ImageBasedJDBCAdaptor, AxionJDBCAdapter, BytesJDBCAdapter, MySqlJDBCAdapter, DB2JDBCAdapter, BlobJDBCAdapter, InformixJDBCAdapter, SybaseJDBCAdapter, HsqldbJDBCAdapter, MaxDBJDBCAdapter, OracleJDBCAdapter, StreamJDBCAdapter

Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.

sub-classing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations.

The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations.

The databases/JDBC drivers that use this adapter are:

Field Summary
protected  Statements statements     
protected  boolean batchStatments     
Method from org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter Summary:
doAddMessage,   doAddMessageReference,   doCreateTables,   doDeleteOldMessages,   doDeleteSubscription,   doDropTables,   doGetAllSubscriptions,   doGetDestinations,   doGetDurableSubscriberMessageCount,   doGetLastAckedDurableSubscriberMessageId,   doGetLastMessageStoreSequenceId,   doGetMessage,   doGetMessageById,   doGetMessageCount,   doGetMessageReference,   doGetNextDurableSubscriberMessageStatement,   doGetSubscriberEntry,   doMessageIdScan,   doRecover,   doRecoverNextMessages,   doRecoverNextMessages,   doRecoverSubscription,   doRemoveAllMessages,   doRemoveMessage,   doSetLastAck,   doSetSubscriberEntry,   getBinaryData,   getStatements,   getStoreSequenceId,   isBatchStatments,   setBatchStatments,   setBinaryData,   setStatements,   setUseExternalMessageReferences
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter 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 destination,
    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 seq) throws SQLException, IOException 
 public byte[] doGetNextDurableSubscriberMessageStatement(TransactionContext c,
    ActiveMQDestination destination,
    String clientId,
    String subscriberName) 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 info,
    boolean retroactive) throws SQLException, IOException 
 protected byte[] getBinaryData(ResultSet rs,
    int index) throws SQLException 
 public Statements getStatements() 
 public long getStoreSequenceId(TransactionContext c,
    MessageId messageID) throws SQLException, IOException 
 public boolean isBatchStatments() 
 public  void setBatchStatments(boolean batchStatments) 
 protected  void setBinaryData(PreparedStatement s,
    int index,
    byte[] data) throws SQLException 
 public  void setStatements(Statements statements) 
 public  void setUseExternalMessageReferences(boolean useExternalMessageReferences)