org.codehaus.activemq.store.bdbn
Class BDbPersistenceAdapter

java.lang.Object
  extended byorg.codehaus.activemq.service.impl.PersistenceAdapterSupport
      extended byorg.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
All Implemented Interfaces:
org.codehaus.activemq.store.PersistenceAdapter, org.codehaus.activemq.service.Service

public class BDbPersistenceAdapter
extends org.codehaus.activemq.service.impl.PersistenceAdapterSupport

Version:
$Revision: 1.1 $

Field Summary
protected  com.sleepycat.db.DbEnv environment
           
 
Constructor Summary
BDbPersistenceAdapter(com.sleepycat.db.DbEnv environment)
           
 
Method Summary
 void beginTransaction()
           
 void commitTransaction()
           
protected  com.sleepycat.db.Db createDatabase(String name)
           
 org.codehaus.activemq.store.PreparedTransactionStore createPreparedTransactionStore()
           
 org.codehaus.activemq.store.MessageStore createQueueMessageStore(String destinationName)
           
 org.codehaus.activemq.store.TopicMessageStore createTopicMessageStore(String destinationName)
           
 Map getInitialDestinations()
           
 void rollbackTransaction()
           
 void start()
           
 void stop()
           
 
Methods inherited from class org.codehaus.activemq.service.impl.PersistenceAdapterSupport
createQueueMessageContainer, createTopicMessageContainer
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

environment

protected com.sleepycat.db.DbEnv environment
Constructor Detail

BDbPersistenceAdapter

public BDbPersistenceAdapter(com.sleepycat.db.DbEnv environment)
Method Detail

getInitialDestinations

public Map getInitialDestinations()

createQueueMessageStore

public org.codehaus.activemq.store.MessageStore createQueueMessageStore(String destinationName)
                                                                 throws JMSException
Throws:
JMSException

createTopicMessageStore

public org.codehaus.activemq.store.TopicMessageStore createTopicMessageStore(String destinationName)

createPreparedTransactionStore

public org.codehaus.activemq.store.PreparedTransactionStore createPreparedTransactionStore()
                                                                                    throws JMSException
Throws:
JMSException

beginTransaction

public void beginTransaction()
                      throws JMSException
Throws:
JMSException

commitTransaction

public void commitTransaction()
                       throws JMSException
Throws:
JMSException

rollbackTransaction

public void rollbackTransaction()

start

public void start()
           throws JMSException
Throws:
JMSException

stop

public void stop()
          throws JMSException
Throws:
JMSException

createDatabase

protected com.sleepycat.db.Db createDatabase(String name)
                                      throws JMSException,
                                             FileNotFoundException,
                                             com.sleepycat.db.DbException
Throws:
JMSException
FileNotFoundException
com.sleepycat.db.DbException


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