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.MessageDeleteListener, 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)
void	addMessageDeleteListener(MessageStore.MessageDeleteListener listener)
void	closeMessageStore()
protected abstract void	doClose()
protected abstract void	doOpen(ConfiguredObject<?> parent)
long	getBytesEvacuatedFromMemory()
protected abstract EnvironmentFacade	getEnvironmentFacade()
long	getInMemorySize()
protected abstract org.slf4j.Logger	getLogger()
long	getNextMessageId()
protected ConfiguredObject<?>	getParent()
protected boolean	isMessageStoreOpen()
boolean	isPersistent()
MessageStore.MessageStoreReader	newMessageStoreReader()
Transaction	newTransaction()
void	openMessageStore(ConfiguredObject<?> parent)
void	removeMessageDeleteListener(MessageStore.MessageDeleteListener listener)
void	upgradeStoreStructure()

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

getStoreLocation, getStoreLocationAsFile, onDelete

Constructor Detail

AbstractBDBMessageStore

public AbstractBDBMessageStore()

Method Detail

openMessageStore

public void openMessageStore(ConfiguredObject<?> parent)

Specified by:

openMessageStore in interface MessageStore

doOpen

protected abstract void doOpen(ConfiguredObject<?> parent)

closeMessageStore

public void closeMessageStore()

Specified by:

closeMessageStore in interface MessageStore

doClose

protected abstract void doClose()

upgradeStoreStructure

public void upgradeStoreStructure()
                           throws StoreException

Specified by:

upgradeStoreStructure in interface MessageStore

Throws:

StoreException

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

getInMemorySize

public long getInMemorySize()

Specified by:

getInMemorySize in interface MessageStore

getBytesEvacuatedFromMemory

public long getBytesEvacuatedFromMemory()

Specified by:

getBytesEvacuatedFromMemory in interface MessageStore

isPersistent

public boolean isPersistent()

Specified by:

isPersistent in interface MessageStore

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

isMessageStoreOpen

protected boolean isMessageStoreOpen()

getParent

protected final ConfiguredObject<?> getParent()

getEnvironmentFacade

protected abstract EnvironmentFacade getEnvironmentFacade()

getLogger

protected abstract org.slf4j.Logger getLogger()

addMessageDeleteListener

public void addMessageDeleteListener(MessageStore.MessageDeleteListener listener)

Specified by:

addMessageDeleteListener in interface MessageStore

removeMessageDeleteListener

public void removeMessageDeleteListener(MessageStore.MessageDeleteListener listener)

Specified by:

removeMessageDeleteListener in interface MessageStore