org.codehaus.activemq.store.jdbm
Class JdbmPersistenceAdapter

java.lang.Object
  extended byorg.codehaus.activemq.service.impl.PersistenceAdapterSupport
      extended byorg.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 $

Constructor Summary
JdbmPersistenceAdapter()
           
JdbmPersistenceAdapter(File directory)
           
JdbmPersistenceAdapter(jdbm.RecordManager manager)
           
 
Method Summary
 void beginTransaction()
           
 void commitTransaction()
           
 jdbm.btree.BTree 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)
           
 File getDirectory()
           
 Map getInitialDestinations()
           
 jdbm.RecordManager getManager()
           
static JdbmPersistenceAdapter newInstance(File directory)
          Factory method to create an instance using the defaults
 void rollbackTransaction()
           
 void setDirectory(File directory)
           
 void setManager(jdbm.RecordManager manager)
           
 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

JdbmPersistenceAdapter

public JdbmPersistenceAdapter()

JdbmPersistenceAdapter

public JdbmPersistenceAdapter(File directory)

JdbmPersistenceAdapter

public JdbmPersistenceAdapter(jdbm.RecordManager manager)
Method Detail

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.