|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.impl.PersistenceAdapterSupport
org.codehaus.activemq.store.bdb.BDbPersistenceAdapter
A PersistenceAdapter
implementation using
Berkeley DB Java Edition
Constructor Summary | |
BDbPersistenceAdapter()
|
|
BDbPersistenceAdapter(com.sleepycat.je.Environment environment,
WireFormat wireFormat)
|
|
BDbPersistenceAdapter(com.sleepycat.je.Environment environment,
WireFormat wireFormat,
com.sleepycat.je.DatabaseConfig config,
com.sleepycat.je.TransactionConfig transactionConfig)
|
|
BDbPersistenceAdapter(File directory)
|
Method Summary | |
void |
beginTransaction()
This method starts a transaction on the persistent storage - which is nothing to do with JMS or XA transactions - its purely a mechanism to perform multiple writes to a persistent store in 1 transaction as a performance optimisation. |
static JMSException |
closeDatabase(com.sleepycat.je.Database db,
JMSException firstException)
|
void |
commitTransaction()
Commit a persistence transaction |
protected com.sleepycat.je.Database |
createDatabase(String name)
|
PreparedTransactionStore |
createPreparedTransactionStore()
Factory method to create a new persistent prepared transaction store for XA recovery |
MessageStore |
createQueueMessageStore(String destinationName)
Factory method to create a new queue message store with the given destination name |
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)
|
TopicMessageStore |
createTopicMessageStore(String destinationName)
Factory method to create a new topic message store with the given destination name |
com.sleepycat.je.DatabaseConfig |
getConfig()
|
File |
getDirectory()
|
com.sleepycat.je.Environment |
getEnvironment()
|
Map |
getInitialDestinations()
Returns a map, indexed by String name, of all the Destination
objects active on startup. |
com.sleepycat.je.TransactionConfig |
getTransactionConfig()
|
WireFormat |
getWireFormat()
|
static BDbPersistenceAdapter |
newInstance(File directory)
Factory method to create an instance using the defaults |
void |
rollbackTransaction()
Rollback a persistence transaction |
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(WireFormat wireFormat)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
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 |
public BDbPersistenceAdapter()
public BDbPersistenceAdapter(File directory)
public BDbPersistenceAdapter(com.sleepycat.je.Environment environment, WireFormat wireFormat)
public BDbPersistenceAdapter(com.sleepycat.je.Environment environment, WireFormat wireFormat, com.sleepycat.je.DatabaseConfig config, com.sleepycat.je.TransactionConfig transactionConfig)
Method Detail |
public static BDbPersistenceAdapter newInstance(File directory) throws JMSException
directory
- the directory in which to store the persistent files
JMSException
public Map getInitialDestinations()
PersistenceAdapter
Destination
objects active on startup.
public MessageStore createQueueMessageStore(String destinationName) throws JMSException
PersistenceAdapter
JMSException
public TopicMessageStore createTopicMessageStore(String destinationName) throws JMSException
PersistenceAdapter
JMSException
public PreparedTransactionStore createPreparedTransactionStore() throws JMSException
PersistenceAdapter
JMSException
public void beginTransaction() throws JMSException
PersistenceAdapter
JMSException
public void commitTransaction() throws JMSException
PersistenceAdapter
JMSException
PersistenceAdapter.beginTransaction()
public void rollbackTransaction()
PersistenceAdapter
PersistenceAdapter.beginTransaction()
public void start() throws JMSException
Service
JMSException
public void stop() throws JMSException
Service
JMSException
public File getDirectory()
public void setDirectory(File directory)
public WireFormat getWireFormat()
public void setWireFormat(WireFormat wireFormat)
public com.sleepycat.je.TransactionConfig getTransactionConfig()
public void setTransactionConfig(com.sleepycat.je.TransactionConfig transactionConfig)
public com.sleepycat.je.Environment getEnvironment()
public void setEnvironment(com.sleepycat.je.Environment environment)
public com.sleepycat.je.DatabaseConfig getConfig()
public void setConfig(com.sleepycat.je.DatabaseConfig config)
protected com.sleepycat.je.Database createDatabase(String name) throws com.sleepycat.je.DatabaseException
com.sleepycat.je.DatabaseException
protected com.sleepycat.je.SecondaryDatabase createSecondaryDatabase(String name, com.sleepycat.je.Database database, com.sleepycat.je.SecondaryConfig secondaryConfig) throws com.sleepycat.je.DatabaseException
com.sleepycat.je.DatabaseException
public static JMSException closeDatabase(com.sleepycat.je.Database db, JMSException firstException)
protected com.sleepycat.je.SecondaryConfig createSecondaryConfig(com.sleepycat.je.SecondaryKeyCreator keyGenerator)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |