org.apache.qpid.server.store

Class MemoryMessageStore

java.lang.Object

org.apache.qpid.server.store.MemoryMessageStore

All Implemented Interfaces:

MessageStore

public class MemoryMessageStore
extends Object
implements MessageStore

A simple message store that stores the messages in a thread-safe structure in memory.

Nested Class Summary

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

MessageStore.MessageStoreReader

Field Summary

Fields

Modifier and Type	Field and Description
static String	TYPE

Constructor Summary

Constructors

Constructor and Description
MemoryMessageStore()

Method Summary

Modifier and Type	Method and Description
void	addEventListener(EventListener eventListener, Event... events)
<T extends StorableMessageMetaData> MessageHandle<T>	addMessage(T metaData)
void	closeMessageStore() Called to close and cleanup any resources used by the message store.
long	getNextMessageId()
String	getStoreLocation()
File	getStoreLocationAsFile()
boolean	isPersistent() Is this store capable of persisting the data
MessageStore.MessageStoreReader	newMessageStoreReader()
Transaction	newTransaction()
void	onDelete(ConfiguredObject<?> parent)
void	openMessageStore(ConfiguredObject<?> parent) Initializes and opens the message store.
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

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

Constructor Detail

MemoryMessageStore

public MemoryMessageStore()

Method Detail

openMessageStore

public void openMessageStore(ConfiguredObject<?> parent)

Description copied from interface: MessageStore

Initializes and opens the message store.

Specified by:

openMessageStore in interface MessageStore

Parameters:

parent - parent object

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

closeMessageStore

public void closeMessageStore()

Description copied from interface: MessageStore

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

Specified by:

closeMessageStore in interface MessageStore

addEventListener

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

Specified by:

addEventListener in interface MessageStore

getStoreLocation

public String getStoreLocation()

Specified by:

getStoreLocation in interface MessageStore

getStoreLocationAsFile

public File getStoreLocationAsFile()

Specified by:

getStoreLocationAsFile in interface MessageStore

onDelete

public void onDelete(ConfiguredObject<?> parent)

Specified by:

onDelete in interface MessageStore

newMessageStoreReader

public MessageStore.MessageStoreReader newMessageStoreReader()

Specified by:

newMessageStoreReader in interface MessageStore