org.apache.activemq.store.jdbc

Interface JDBCAdapter

All Known Implementing Classes:

AxionJDBCAdapter, BlobJDBCAdapter, BytesJDBCAdapter, DB2JDBCAdapter, DefaultJDBCAdapter, HsqldbJDBCAdapter, ImageBasedJDBCAdaptor, InformixJDBCAdapter, MaxDBJDBCAdapter, MySqlJDBCAdapter, OracleBlobJDBCAdapter, OracleJDBCAdapter, PostgresqlJDBCAdapter, StreamJDBCAdapter, SybaseJDBCAdapter, TransactJDBCAdapter

public interface JDBCAdapter

Method Summary

Methods

Modifier and Type	Method and Description
void	doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
void	doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, java.lang.String messageRef)
void	doClearLastAck(TransactionContext c, ActiveMQDestination destination, byte priority, java.lang.String subId, java.lang.String subName)
void	doCommitAddOp(TransactionContext c, long storeSequenceIdForMessageId)
void	doCreateTables(TransactionContext c)
void	doDeleteOldMessages(TransactionContext c)
void	doDeleteSubscription(TransactionContext c, ActiveMQDestination destinationName, java.lang.String clientId, java.lang.String subscriptionName)
void	doDropTables(TransactionContext c)
SubscriptionInfo[]	doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination)
java.util.Set<ActiveMQDestination>	doGetDestinations(TransactionContext c)
int	doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, boolean isPrioritizeMessages)
long	doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriberName)
long	doGetLastMessageStoreSequenceId(TransactionContext c)
long	doGetLastProducerSequenceId(TransactionContext c, ProducerId id)
byte[]	doGetMessage(TransactionContext c, MessageId id)
byte[]	doGetMessageById(TransactionContext c, long storeSequenceId)
int	doGetMessageCount(TransactionContext c, ActiveMQDestination destination)
java.lang.String	doGetMessageReference(TransactionContext c, long id)
SubscriptionInfo	doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName)
void	doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener)
void	doRecordDestination(TransactionContext c, ActiveMQDestination destination)
void	doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener)
void	doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long nextSeq, long priority, int maxReturned, boolean isPrioritizeMessages, JDBCMessageRecoveryListener listener)
void	doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
void	doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener)
void	doRecoverPreparedOps(TransactionContext c, JdbcMemoryTransactionStore jdbcMemoryTransactionStore)
void	doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, JDBCMessageRecoveryListener listener)
void	doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName)
void	doRemoveMessage(TransactionContext c, long seq, XATransactionId xid)
void	doSetLastAck(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, java.lang.String clientId, java.lang.String subscriptionName, long seq, long prio)
void	doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, XATransactionId xid, java.lang.String clientId, java.lang.String subscriptionName, long re, long re1)
void	doSetSubscriberEntry(TransactionContext c, SubscriptionInfo subscriptionInfo, boolean retroactive, boolean isPrioritizeMessages)
int	getMaxRows()
long[]	getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)
void	setMaxRows(int maxRows)
void	setStatements(Statements statementProvider)
void	setUseExternalMessageReferences(boolean useExternalMessageReferences)

Method Detail

setStatements

void setStatements(Statements statementProvider)

doCreateTables

void doCreateTables(TransactionContext c)
                    throws java.sql.SQLException,
                           java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doDropTables

void doDropTables(TransactionContext c)
                  throws java.sql.SQLException,
                         java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doAddMessage

void doAddMessage(TransactionContext c,
                long sequence,
                MessageId messageID,
                ActiveMQDestination destination,
                byte[] data,
                long expiration,
                byte priority,
                XATransactionId xid)
                  throws java.sql.SQLException,
                         java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doAddMessageReference

void doAddMessageReference(TransactionContext c,
                         long sequence,
                         MessageId messageId,
                         ActiveMQDestination destination,
                         long expirationTime,
                         java.lang.String messageRef)
                           throws java.sql.SQLException,
                                  java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetMessage

byte[] doGetMessage(TransactionContext c,
                  MessageId id)
                    throws java.sql.SQLException,
                           java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetMessageById

byte[] doGetMessageById(TransactionContext c,
                      long storeSequenceId)
                        throws java.sql.SQLException,
                               java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetMessageReference

java.lang.String doGetMessageReference(TransactionContext c,
                                     long id)
                                       throws java.sql.SQLException,
                                              java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doRemoveMessage

void doRemoveMessage(TransactionContext c,
                   long seq,
                   XATransactionId xid)
                     throws java.sql.SQLException,
                            java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doRecover

void doRecover(TransactionContext c,
             ActiveMQDestination destination,
             JDBCMessageRecoveryListener listener)
               throws java.lang.Exception

Throws:

java.lang.Exception

doSetLastAck

void doSetLastAck(TransactionContext c,
                ActiveMQDestination destination,
                XATransactionId xid,
                java.lang.String clientId,
                java.lang.String subscriptionName,
                long seq,
                long prio)
                  throws java.sql.SQLException,
                         java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doRecoverSubscription

void doRecoverSubscription(TransactionContext c,
                         ActiveMQDestination destination,
                         java.lang.String clientId,
                         java.lang.String subscriptionName,
                         JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception

Throws:

java.lang.Exception

doRecoverNextMessages

void doRecoverNextMessages(TransactionContext c,
                         ActiveMQDestination destination,
                         java.lang.String clientId,
                         java.lang.String subscriptionName,
                         long seq,
                         long priority,
                         int maxReturned,
                         JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception

Throws:

java.lang.Exception

doRecoverNextMessagesWithPriority

void doRecoverNextMessagesWithPriority(TransactionContext c,
                                     ActiveMQDestination destination,
                                     java.lang.String clientId,
                                     java.lang.String subscriptionName,
                                     long seq,
                                     long priority,
                                     int maxReturned,
                                     JDBCMessageRecoveryListener listener)
                                       throws java.lang.Exception

Throws:

java.lang.Exception

doSetSubscriberEntry

void doSetSubscriberEntry(TransactionContext c,
                        SubscriptionInfo subscriptionInfo,
                        boolean retroactive,
                        boolean isPrioritizeMessages)
                          throws java.sql.SQLException,
                                 java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetSubscriberEntry

SubscriptionInfo doGetSubscriberEntry(TransactionContext c,
                                    ActiveMQDestination destination,
                                    java.lang.String clientId,
                                    java.lang.String subscriptionName)
                                      throws java.sql.SQLException,
                                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

getStoreSequenceId

long[] getStoreSequenceId(TransactionContext c,
                        ActiveMQDestination destination,
                        MessageId messageID)
                          throws java.sql.SQLException,
                                 java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doRemoveAllMessages

void doRemoveAllMessages(TransactionContext c,
                       ActiveMQDestination destinationName)
                         throws java.sql.SQLException,
                                java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doDeleteSubscription

void doDeleteSubscription(TransactionContext c,
                        ActiveMQDestination destinationName,
                        java.lang.String clientId,
                        java.lang.String subscriptionName)
                          throws java.sql.SQLException,
                                 java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doDeleteOldMessages

void doDeleteOldMessages(TransactionContext c)
                         throws java.sql.SQLException,
                                java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetLastMessageStoreSequenceId

long doGetLastMessageStoreSequenceId(TransactionContext c)
                                     throws java.sql.SQLException,
                                            java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetDestinations

java.util.Set<ActiveMQDestination> doGetDestinations(TransactionContext c)
                                                     throws java.sql.SQLException,
                                                            java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

setUseExternalMessageReferences

void setUseExternalMessageReferences(boolean useExternalMessageReferences)

doGetAllSubscriptions

SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c,
                                       ActiveMQDestination destination)
                                         throws java.sql.SQLException,
                                                java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetDurableSubscriberMessageCount

int doGetDurableSubscriberMessageCount(TransactionContext c,
                                     ActiveMQDestination destination,
                                     java.lang.String clientId,
                                     java.lang.String subscriptionName,
                                     boolean isPrioritizeMessages)
                                       throws java.sql.SQLException,
                                              java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetMessageCount

int doGetMessageCount(TransactionContext c,
                    ActiveMQDestination destination)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doRecoverNextMessages

void doRecoverNextMessages(TransactionContext c,
                         ActiveMQDestination destination,
                         long nextSeq,
                         long priority,
                         int maxReturned,
                         boolean isPrioritizeMessages,
                         JDBCMessageRecoveryListener listener)
                           throws java.lang.Exception

Throws:

java.lang.Exception

doGetLastAckedDurableSubscriberMessageId

long doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
                                            ActiveMQDestination destination,
                                            java.lang.String clientId,
                                            java.lang.String subscriberName)
                                              throws java.sql.SQLException,
                                                     java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doMessageIdScan

void doMessageIdScan(TransactionContext c,
                   int limit,
                   JDBCMessageIdScanListener listener)
                     throws java.sql.SQLException,
                            java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doGetLastProducerSequenceId

long doGetLastProducerSequenceId(TransactionContext c,
                               ProducerId id)
                                 throws java.sql.SQLException,
                                        java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doSetLastAckWithPriority

void doSetLastAckWithPriority(TransactionContext c,
                            ActiveMQDestination destination,
                            XATransactionId xid,
                            java.lang.String clientId,
                            java.lang.String subscriptionName,
                            long re,
                            long re1)
                              throws java.sql.SQLException,
                                     java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

getMaxRows

int getMaxRows()

setMaxRows

void setMaxRows(int maxRows)

doRecordDestination

void doRecordDestination(TransactionContext c,
                       ActiveMQDestination destination)
                         throws java.sql.SQLException,
                                java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doRecoverPreparedOps

void doRecoverPreparedOps(TransactionContext c,
                        JdbcMemoryTransactionStore jdbcMemoryTransactionStore)
                          throws java.sql.SQLException,
                                 java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doCommitAddOp

void doCommitAddOp(TransactionContext c,
                 long storeSequenceIdForMessageId)
                   throws java.sql.SQLException,
                          java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

doClearLastAck

void doClearLastAck(TransactionContext c,
                  ActiveMQDestination destination,
                  byte priority,
                  java.lang.String subId,
                  java.lang.String subName)
                    throws java.sql.SQLException,
                           java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException