org.apache.qpid.server.store.berkeleydb

Class AbstractBDBMessageStore

java.lang.Object

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

All Implemented Interfaces:

MessageStore

Direct Known Subclasses:

BDBMessageStore

public abstract class AbstractBDBMessageStore
extends Object
implements MessageStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractBDBMessageStore.BDBEnqueueRecord

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

MessageStore.MessageStoreReader

Constructor Summary

Constructors

Constructor and Description
AbstractBDBMessageStore()

Method Summary

Modifier and Type	Method and Description
void	addEventListener(EventListener eventListener, Event... events)
<T extends StorableMessageMetaData> MessageHandle<T>	addMessage(T metaData)
protected abstract void	checkMessageStoreOpen()
protected abstract EnvironmentFacade	getEnvironmentFacade()
protected abstract org.slf4j.Logger	getLogger()
long	getNextMessageId()
protected abstract ConfiguredObject<?>	getParent()
protected abstract long	getPersistentSizeHighThreshold()
protected abstract long	getPersistentSizeLowThreshold()
boolean	isPersistent() Is this store capable of persisting the data
MessageStore.MessageStoreReader	newMessageStoreReader()
Transaction	newTransaction()
void	upgradeStoreStructure() Requests that the store performs any upgrade work on the store's structure.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.qpid.server.store.MessageStore

closeMessageStore, getStoreLocation, getStoreLocationAsFile, onDelete, openMessageStore

Constructor Detail

AbstractBDBMessageStore

public AbstractBDBMessageStore()

Method Detail

upgradeStoreStructure

public void upgradeStoreStructure()
                           throws StoreException

Description copied from interface: MessageStore

Requests that the store performs any upgrade work on the store's structure. If there is no upgrade work to be done, this method should return without doing anything.

Specified by:

upgradeStoreStructure in interface MessageStore

Throws:

StoreException - signals that a problem was encountered trying to upgrade the store. Implementations, on encountering a problem, should endeavour to leave the store in its original state.

addMessage

public <T extends StorableMessageMetaData> MessageHandle<T> addMessage(T metaData)

Specified by:

addMessage in interface MessageStore

getNextMessageId

public long getNextMessageId()

Specified by:

getNextMessageId in interface MessageStore

isPersistent

public boolean isPersistent()

Description copied from interface: MessageStore

Is this store capable of persisting the data

Specified by:

isPersistent in interface MessageStore

Returns:

true if this store is capable of persisting data

newTransaction

public Transaction newTransaction()

Specified by:

newTransaction in interface MessageStore

addEventListener

public void addEventListener(EventListener eventListener,
                             Event... events)

Specified by:

addEventListener in interface MessageStore

newMessageStoreReader

public MessageStore.MessageStoreReader newMessageStoreReader()

Specified by:

newMessageStoreReader in interface MessageStore

checkMessageStoreOpen

protected abstract void checkMessageStoreOpen()

getParent

protected abstract ConfiguredObject<?> getParent()

getEnvironmentFacade

protected abstract EnvironmentFacade getEnvironmentFacade()

getPersistentSizeLowThreshold

protected abstract long getPersistentSizeLowThreshold()

getPersistentSizeHighThreshold

protected abstract long getPersistentSizeHighThreshold()

getLogger

protected abstract org.slf4j.Logger getLogger()