org.codehaus.activemq.store.bdb
Class BDbPreparedTransactionStore

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

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

Version:
$Revision: 1.1 $

Constructor Summary
BDbPreparedTransactionStore(com.sleepycat.je.Database database)
           
 
Method Summary
protected  void checkClosed()
           
protected  org.codehaus.activemq.service.Transaction extractTransaction(com.sleepycat.je.DatabaseEntry entry)
           
protected  org.codehaus.activemq.message.ActiveMQXid extractXid(com.sleepycat.je.DatabaseEntry entry)
           
 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

BDbPreparedTransactionStore

public BDbPreparedTransactionStore(com.sleepycat.je.Database 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

extractXid

protected org.codehaus.activemq.message.ActiveMQXid extractXid(com.sleepycat.je.DatabaseEntry entry)
                                                        throws IOException
Throws:
IOException

extractTransaction

protected org.codehaus.activemq.service.Transaction extractTransaction(com.sleepycat.je.DatabaseEntry entry)
                                                                throws IOException,
                                                                       ClassNotFoundException
Throws:
IOException
ClassNotFoundException

checkClosed

protected void checkClosed()
                    throws XAException
Throws:
XAException


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.