org.codehaus.activemq.store.jdbc
Class JDBCPreparedTransactionStore
java.lang.Object
org.codehaus.activemq.store.jdbc.JDBCPreparedTransactionStore
- All Implemented Interfaces:
- org.codehaus.activemq.store.PreparedTransactionStore, org.codehaus.activemq.service.Service
- public class JDBCPreparedTransactionStore
- extends Object
- implements org.codehaus.activemq.store.PreparedTransactionStore
- Version:
- $Revision: 1.2 $
Method Summary |
org.codehaus.activemq.message.ActiveMQXid[] |
getXids()
|
void |
loadPreparedTransactions(org.codehaus.activemq.service.TransactionManager transactionManager)
|
void |
put(org.codehaus.activemq.message.ActiveMQXid xid,
org.codehaus.activemq.service.Transaction transaction)
|
void |
remove(org.codehaus.activemq.message.ActiveMQXid xid)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JDBCPreparedTransactionStore
public JDBCPreparedTransactionStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
org.codehaus.activemq.io.WireFormat wireFormat)
getXids
public org.codehaus.activemq.message.ActiveMQXid[] getXids()
throws XAException
- Specified by:
getXids
in interface org.codehaus.activemq.store.PreparedTransactionStore
- Throws:
XAException
remove
public void remove(org.codehaus.activemq.message.ActiveMQXid xid)
throws XAException
- Specified by:
remove
in interface org.codehaus.activemq.store.PreparedTransactionStore
- Throws:
XAException
put
public void put(org.codehaus.activemq.message.ActiveMQXid xid,
org.codehaus.activemq.service.Transaction transaction)
throws XAException
- Specified by:
put
in interface org.codehaus.activemq.store.PreparedTransactionStore
- Throws:
XAException
loadPreparedTransactions
public void loadPreparedTransactions(org.codehaus.activemq.service.TransactionManager transactionManager)
throws XAException
- Specified by:
loadPreparedTransactions
in interface org.codehaus.activemq.store.PreparedTransactionStore
- Throws:
XAException
start
public void start()
throws JMSException
- Specified by:
start
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Specified by:
stop
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.