org.activemq.store.jdbc
Interface JDBCAdapter
- All Known Implementing Classes:
- AxionJDBCAdapter, BlobJDBCAdapter, BytesJDBCAdapter, DefaultJDBCAdapter, HsqldbJDBCAdapter, ImageBasedJDBCAdaptor, InformixJDBCAdapter, OracleJDBCAdapter, PostgresqlJDBCAdapter, StreamJDBCAdapter
public interface JDBCAdapter
- Version:
- $Revision: 1.1 $
Method Summary |
void |
doAddMessage(Connection c,
long seq,
String messageID,
String destinationName,
byte[] data,
long expiration)
|
void |
doAddXid(Connection c,
ActiveMQXid xid)
|
void |
doCreateTables(Connection c)
|
void |
doDeleteExpiredMessage(Connection c,
MessageIdentity messageIdentity)
|
void |
doDeleteOldMessages(Connection c)
|
void |
doDeleteSubscription(Connection c,
String destinationName,
String subscription)
|
void |
doDropTables(Connection c)
|
void |
doGetExpiredMessages(Connection c,
JDBCAdapter.ExpiredMessageResultHandler handler)
|
byte[] |
doGetMessage(Connection c,
long seq)
|
void |
doGetMessageForUpdate(Connection c,
long seq,
boolean useLocking,
JDBCAdapter.ExpiredMessageResultHandler handler)
|
SubscriberEntry |
doGetSubscriberEntry(Connection c,
String destinationName,
String sub)
|
void |
doLoadPreparedTransactions(Connection c,
TransactionStore.RecoveryListener listener)
|
void |
doRecover(Connection c,
String destinationName,
JDBCAdapter.MessageListResultHandler listener)
|
void |
doRecoverSubscription(Connection c,
String destinationName,
String sub,
JDBCAdapter.MessageListResultHandler listener)
|
void |
doRemoveAllMessages(Connection c,
String destinationName)
|
void |
doRemoveMessage(Connection c,
long seq)
|
void |
doRemoveXid(Connection c,
ActiveMQXid xid)
|
void |
doSetDeadLetterFlag(Connection c,
long seq)
|
void |
doSetLastAck(Connection c,
String destinationName,
String sub,
long seq)
|
void |
doSetSubscriberEntry(Connection c,
String destinationName,
String sub,
SubscriberEntry subscriberEntry)
|
Long |
getMessageSequenceId(Connection c,
String messageID)
|
LongSequenceGenerator |
getSequenceGenerator()
|
StatementProvider |
getStatementProvider()
|
void |
initSequenceGenerator(Connection c)
|
getSequenceGenerator
LongSequenceGenerator getSequenceGenerator()
doCreateTables
void doCreateTables(Connection c)
throws SQLException
- Throws:
SQLException
doDropTables
void doDropTables(Connection c)
throws SQLException
- Throws:
SQLException
initSequenceGenerator
void initSequenceGenerator(Connection c)
doAddMessage
void doAddMessage(Connection c,
long seq,
String messageID,
String destinationName,
byte[] data,
long expiration)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doGetMessage
byte[] doGetMessage(Connection c,
long seq)
throws SQLException
- Throws:
SQLException
doGetMessageForUpdate
void doGetMessageForUpdate(Connection c,
long seq,
boolean useLocking,
JDBCAdapter.ExpiredMessageResultHandler handler)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doRemoveMessage
void doRemoveMessage(Connection c,
long seq)
throws SQLException
- Throws:
SQLException
doRecover
void doRecover(Connection c,
String destinationName,
JDBCAdapter.MessageListResultHandler listener)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doRemoveXid
void doRemoveXid(Connection c,
ActiveMQXid xid)
throws SQLException,
XAException
- Throws:
SQLException
XAException
doAddXid
void doAddXid(Connection c,
ActiveMQXid xid)
throws SQLException,
XAException
- Throws:
SQLException
XAException
doLoadPreparedTransactions
void doLoadPreparedTransactions(Connection c,
TransactionStore.RecoveryListener listener)
throws SQLException
- Throws:
SQLException
doSetLastAck
void doSetLastAck(Connection c,
String destinationName,
String sub,
long seq)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doRecoverSubscription
void doRecoverSubscription(Connection c,
String destinationName,
String sub,
JDBCAdapter.MessageListResultHandler listener)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doSetSubscriberEntry
void doSetSubscriberEntry(Connection c,
String destinationName,
String sub,
SubscriberEntry subscriberEntry)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doGetSubscriberEntry
SubscriberEntry doGetSubscriberEntry(Connection c,
String destinationName,
String sub)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
getMessageSequenceId
Long getMessageSequenceId(Connection c,
String messageID)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doRemoveAllMessages
void doRemoveAllMessages(Connection c,
String destinationName)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doDeleteSubscription
void doDeleteSubscription(Connection c,
String destinationName,
String subscription)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doDeleteOldMessages
void doDeleteOldMessages(Connection c)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doGetExpiredMessages
void doGetExpiredMessages(Connection c,
JDBCAdapter.ExpiredMessageResultHandler handler)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doDeleteExpiredMessage
void doDeleteExpiredMessage(Connection c,
MessageIdentity messageIdentity)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
doSetDeadLetterFlag
void doSetDeadLetterFlag(Connection c,
long seq)
throws SQLException,
JMSException
- Throws:
SQLException
JMSException
getStatementProvider
StatementProvider getStatementProvider()
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.