org.codehaus.activemq.store.bdb
Class BDbPersistenceAdapter
java.lang.Object
org.codehaus.activemq.service.impl.PersistenceAdapterSupport
org.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 $
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 |
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)
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.