org.activemq.store.jdbc
Interface JDBCAdapter
- All Known Implementing Classes:
- DefaultJDBCAdapter
- public interface JDBCAdapter
- Version:
- $Revision: 1.1 $
Method Summary |
void |
doAddMessage(java.sql.Connection c,
long seq,
java.lang.String messageID,
java.lang.String destinationName,
byte[] data,
long expiration)
|
void |
doAddXid(java.sql.Connection c,
ActiveMQXid xid)
|
void |
doCreateTables(java.sql.Connection c)
|
void |
doDeleteOldMessages(java.sql.Connection c)
|
void |
doDeleteSubscription(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String subscription)
|
void |
doDropTables(java.sql.Connection c)
|
byte[] |
doGetMessage(java.sql.Connection c,
long seq)
|
SubscriberEntry |
doGetSubscriberEntry(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub)
|
void |
doLoadPreparedTransactions(java.sql.Connection c,
TransactionStore.RecoveryListener listener)
|
void |
doRecover(java.sql.Connection c,
java.lang.String destinationName,
JDBCAdapter.MessageListResultHandler listener)
|
void |
doRecoverSubscription(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub,
JDBCAdapter.MessageListResultHandler listener)
|
void |
doRemoveAllMessages(java.sql.Connection c,
java.lang.String destinationName)
|
void |
doRemoveMessage(java.sql.Connection c,
long seq)
|
void |
doRemoveXid(java.sql.Connection c,
ActiveMQXid xid)
|
void |
doSetLastAck(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub,
long seq)
|
void |
doSetSubscriberEntry(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub,
SubscriberEntry subscriberEntry)
|
java.lang.Long |
getMessageSequenceId(java.sql.Connection c,
java.lang.String messageID)
|
LongSequenceGenerator |
getSequenceGenerator()
|
void |
initSequenceGenerator(java.sql.Connection c)
|
getSequenceGenerator
public LongSequenceGenerator getSequenceGenerator()
doCreateTables
public void doCreateTables(java.sql.Connection c)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
doDropTables
public void doDropTables(java.sql.Connection c)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
initSequenceGenerator
public void initSequenceGenerator(java.sql.Connection c)
doAddMessage
public void doAddMessage(java.sql.Connection c,
long seq,
java.lang.String messageID,
java.lang.String destinationName,
byte[] data,
long expiration)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doGetMessage
public byte[] doGetMessage(java.sql.Connection c,
long seq)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
doRemoveMessage
public void doRemoveMessage(java.sql.Connection c,
long seq)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
doRecover
public void doRecover(java.sql.Connection c,
java.lang.String destinationName,
JDBCAdapter.MessageListResultHandler listener)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doRemoveXid
public void doRemoveXid(java.sql.Connection c,
ActiveMQXid xid)
throws java.sql.SQLException,
javax.transaction.xa.XAException
- Throws:
java.sql.SQLException
javax.transaction.xa.XAException
doAddXid
public void doAddXid(java.sql.Connection c,
ActiveMQXid xid)
throws java.sql.SQLException,
javax.transaction.xa.XAException
- Throws:
java.sql.SQLException
javax.transaction.xa.XAException
doLoadPreparedTransactions
public void doLoadPreparedTransactions(java.sql.Connection c,
TransactionStore.RecoveryListener listener)
throws java.sql.SQLException
- Throws:
java.sql.SQLException
doSetLastAck
public void doSetLastAck(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub,
long seq)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doRecoverSubscription
public void doRecoverSubscription(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub,
JDBCAdapter.MessageListResultHandler listener)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doSetSubscriberEntry
public void doSetSubscriberEntry(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub,
SubscriberEntry subscriberEntry)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doGetSubscriberEntry
public SubscriberEntry doGetSubscriberEntry(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String sub)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
getMessageSequenceId
public java.lang.Long getMessageSequenceId(java.sql.Connection c,
java.lang.String messageID)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doRemoveAllMessages
public void doRemoveAllMessages(java.sql.Connection c,
java.lang.String destinationName)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doDeleteSubscription
public void doDeleteSubscription(java.sql.Connection c,
java.lang.String destinationName,
java.lang.String subscription)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
doDeleteOldMessages
public void doDeleteOldMessages(java.sql.Connection c)
throws java.sql.SQLException,
javax.jms.JMSException
- Throws:
java.sql.SQLException
javax.jms.JMSException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.