org.codehaus.activemq.store.bdb
Class BDbPersistenceAdapter

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

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

A PersistenceAdapter implementation using Berkeley DB Java Edition

Version:
$Revision: 1.2 $

Constructor Summary
BDbPersistenceAdapter()
           
BDbPersistenceAdapter(com.sleepycat.je.Environment environment, org.codehaus.activemq.io.WireFormat wireFormat)
           
BDbPersistenceAdapter(com.sleepycat.je.Environment environment, org.codehaus.activemq.io.WireFormat wireFormat, com.sleepycat.je.DatabaseConfig config, com.sleepycat.je.TransactionConfig transactionConfig)
           
BDbPersistenceAdapter(File directory)
           
 
Method Summary
 void beginTransaction()
           
static JMSException closeDatabase(com.sleepycat.je.Database db, JMSException firstException)
           
 void commitTransaction()
           
protected  com.sleepycat.je.Database createDatabase(String name)
           
 org.codehaus.activemq.store.PreparedTransactionStore createPreparedTransactionStore()
           
 org.codehaus.activemq.store.MessageStore createQueueMessageStore(String destinationName)
           
protected  com.sleepycat.je.SecondaryConfig createSecondaryConfig(com.sleepycat.je.SecondaryKeyCreator keyGenerator)
           
protected  com.sleepycat.je.SecondaryDatabase createSecondaryDatabase(String name, com.sleepycat.je.Database database, com.sleepycat.je.SecondaryConfig secondaryConfig)
           
 org.codehaus.activemq.store.TopicMessageStore createTopicMessageStore(String destinationName)
           
 com.sleepycat.je.DatabaseConfig getConfig()
           
 File getDirectory()
           
 com.sleepycat.je.Environment getEnvironment()
           
 Map getInitialDestinations()
           
 com.sleepycat.je.TransactionConfig getTransactionConfig()
           
 org.codehaus.activemq.io.WireFormat getWireFormat()
           
static BDbPersistenceAdapter newInstance(File directory)
          Factory method to create an instance using the defaults
 void rollbackTransaction()
           
 void setConfig(com.sleepycat.je.DatabaseConfig config)
           
 void setDirectory(File directory)
           
 void setEnvironment(com.sleepycat.je.Environment environment)
           
 void setTransactionConfig(com.sleepycat.je.TransactionConfig transactionConfig)
           
 void setWireFormat(org.codehaus.activemq.io.WireFormat wireFormat)
           
 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
 

Constructor Detail

BDbPersistenceAdapter

public BDbPersistenceAdapter()

BDbPersistenceAdapter

public BDbPersistenceAdapter(File directory)

BDbPersistenceAdapter

public BDbPersistenceAdapter(com.sleepycat.je.Environment environment,
                             org.codehaus.activemq.io.WireFormat wireFormat)

BDbPersistenceAdapter

public BDbPersistenceAdapter(com.sleepycat.je.Environment environment,
                             org.codehaus.activemq.io.WireFormat wireFormat,
                             com.sleepycat.je.DatabaseConfig config,
                             com.sleepycat.je.TransactionConfig transactionConfig)
Method Detail

newInstance

public static BDbPersistenceAdapter newInstance(File directory)
                                         throws JMSException
Factory method to create an instance using the defaults

Parameters:
directory - the directory in which to store the persistent files
Returns:
Throws:
JMSException

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)
                                                                      throws JMSException
Throws:
JMSException

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

getDirectory

public File getDirectory()

setDirectory

public void setDirectory(File directory)

getWireFormat

public org.codehaus.activemq.io.WireFormat getWireFormat()

setWireFormat

public void setWireFormat(org.codehaus.activemq.io.WireFormat wireFormat)

getTransactionConfig

public com.sleepycat.je.TransactionConfig getTransactionConfig()

setTransactionConfig

public void setTransactionConfig(com.sleepycat.je.TransactionConfig transactionConfig)

getEnvironment

public com.sleepycat.je.Environment getEnvironment()

setEnvironment

public void setEnvironment(com.sleepycat.je.Environment environment)

getConfig

public com.sleepycat.je.DatabaseConfig getConfig()

setConfig

public void setConfig(com.sleepycat.je.DatabaseConfig config)

createDatabase

protected com.sleepycat.je.Database createDatabase(String name)
                                            throws com.sleepycat.je.DatabaseException
Throws:
com.sleepycat.je.DatabaseException

createSecondaryDatabase

protected com.sleepycat.je.SecondaryDatabase createSecondaryDatabase(String name,
                                                                     com.sleepycat.je.Database database,
                                                                     com.sleepycat.je.SecondaryConfig secondaryConfig)
                                                              throws com.sleepycat.je.DatabaseException
Throws:
com.sleepycat.je.DatabaseException

closeDatabase

public static JMSException closeDatabase(com.sleepycat.je.Database db,
                                         JMSException firstException)

createSecondaryConfig

protected com.sleepycat.je.SecondaryConfig createSecondaryConfig(com.sleepycat.je.SecondaryKeyCreator keyGenerator)


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