org.codehaus.activemq.store.jdbm
Class JdbmPersistenceAdapter
java.lang.Object
org.codehaus.activemq.service.impl.PersistenceAdapterSupport
org.codehaus.activemq.store.jdbm.JdbmPersistenceAdapter
- All Implemented Interfaces:
- org.codehaus.activemq.store.PersistenceAdapter, org.codehaus.activemq.service.Service
- public class JdbmPersistenceAdapter
- extends org.codehaus.activemq.service.impl.PersistenceAdapterSupport
A PersistenceAdapter
implementation for
JDBM
- Version:
- $Revision: 1.1 $
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 |
JdbmPersistenceAdapter
public JdbmPersistenceAdapter()
JdbmPersistenceAdapter
public JdbmPersistenceAdapter(File directory)
JdbmPersistenceAdapter
public JdbmPersistenceAdapter(jdbm.RecordManager manager)
newInstance
public static JdbmPersistenceAdapter 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()
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
getManager
public jdbm.RecordManager getManager()
setManager
public void setManager(jdbm.RecordManager manager)
getDirectory
public File getDirectory()
setDirectory
public void setDirectory(File directory)
createDatabase
public jdbm.btree.BTree createDatabase(String name)
throws IOException,
org.codehaus.activemq.AlreadyClosedException
- Throws:
IOException
org.codehaus.activemq.AlreadyClosedException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.