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 |
void |
doAddMessage(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority)
|
void |
doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageId,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
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 |
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)
|
void |
doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long prio)
|
void |
doSetLastAckWithPriority(TransactionContext c,
ActiveMQDestination destination,
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)
|
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)
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)
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,
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,
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
Copyright © 2005-2012. All Rights Reserved.