org.apache.qpid.server.store.berkeleydb

Class BDBMessageStore

java.lang.Object

org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore

org.apache.qpid.server.store.berkeleydb.BDBMessageStore

All Implemented Interfaces:

MessageStore

public class BDBMessageStore
extends AbstractBDBMessageStore

Implementation of a MessageStore backed by BDB JE.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore

AbstractBDBMessageStore.BDBEnqueueRecord

Nested classes/interfaces inherited from interface org.apache.qpid.server.store.MessageStore

MessageStore.MessageStoreReader

Constructor Summary

Constructors

Constructor and Description
BDBMessageStore()
BDBMessageStore(EnvironmentFacadeFactory environmentFacadeFactory)

Method Summary

Modifier and Type	Method and Description
protected void	checkMessageStoreOpen()
void	closeMessageStore() Called to close and cleanup any resources used by the message store.
EnvironmentFacade	getEnvironmentFacade()
protected org.slf4j.Logger	getLogger()
protected ConfiguredObject<?>	getParent()
protected long	getPersistentSizeHighThreshold()
protected long	getPersistentSizeLowThreshold()
String	getStoreLocation()
File	getStoreLocationAsFile()
void	onDelete(ConfiguredObject<?> parent)
void	openMessageStore(ConfiguredObject<?> parent) Initializes and opens the message store.

Methods inherited from class org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore

addEventListener, addMessage, getNextMessageId, isPersistent, newMessageStoreReader, newTransaction, upgradeStoreStructure

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BDBMessageStore

public BDBMessageStore()

BDBMessageStore

public BDBMessageStore(EnvironmentFacadeFactory environmentFacadeFactory)

Method Detail

openMessageStore

public void openMessageStore(ConfiguredObject<?> parent)

Description copied from interface: MessageStore

Initializes and opens the message store.

Parameters:

parent - parent object

closeMessageStore

public void closeMessageStore()

Description copied from interface: MessageStore

Called to close and cleanup any resources used by the message store.

onDelete

public void onDelete(ConfiguredObject<?> parent)

getEnvironmentFacade

public EnvironmentFacade getEnvironmentFacade()

Specified by:

getEnvironmentFacade in class AbstractBDBMessageStore

getPersistentSizeLowThreshold

protected long getPersistentSizeLowThreshold()

Specified by:

getPersistentSizeLowThreshold in class AbstractBDBMessageStore

getPersistentSizeHighThreshold

protected long getPersistentSizeHighThreshold()

Specified by:

getPersistentSizeHighThreshold in class AbstractBDBMessageStore

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractBDBMessageStore

checkMessageStoreOpen

protected void checkMessageStoreOpen()

Specified by:

checkMessageStoreOpen in class AbstractBDBMessageStore

getParent

protected ConfiguredObject<?> getParent()

Specified by:

getParent in class AbstractBDBMessageStore

getStoreLocation

public String getStoreLocation()

getStoreLocationAsFile

public File getStoreLocationAsFile()