public interface MessageStore
Modifier and Type | Interface and Description |
---|---|
static interface |
MessageStore.MessageStoreReader |
Modifier and Type | Method and Description |
---|---|
void |
addEventListener(EventListener eventListener,
Event... events) |
<T extends StorableMessageMetaData> |
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.
|
long getNextMessageId()
String getStoreLocation()
File getStoreLocationAsFile()
void addEventListener(EventListener eventListener, Event... events)
void openMessageStore(ConfiguredObject<?> parent)
parent
- parent objectvoid upgradeStoreStructure() throws StoreException
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.<T extends StorableMessageMetaData> MessageHandle<T> addMessage(T metaData)
boolean isPersistent()
Transaction newTransaction()
void closeMessageStore()
void onDelete(ConfiguredObject<?> parent)
MessageStore.MessageStoreReader newMessageStoreReader()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.