org.codehaus.activemq.store.jdbm
Class JdbmPreparedTransactionStore

java.lang.Object
  extended byorg.codehaus.activemq.store.jdbm.JdbmPreparedTransactionStore
All Implemented Interfaces:
org.codehaus.activemq.store.PreparedTransactionStore, org.codehaus.activemq.service.Service

public class JdbmPreparedTransactionStore
extends Object
implements org.codehaus.activemq.store.PreparedTransactionStore

Version:
$Revision: 1.1 $

Constructor Summary
JdbmPreparedTransactionStore(jdbm.btree.BTree database)
           
 
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
 

Constructor Detail

JdbmPreparedTransactionStore

public JdbmPreparedTransactionStore(jdbm.btree.BTree database)
Method Detail

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.