public abstract class AbstractBDBMessageStore extends Object implements MessageStore
Modifier and Type | Class and Description |
---|---|
static class |
AbstractBDBMessageStore.BDBEnqueueRecord |
MessageStore.MessageStoreReader
Constructor and Description |
---|
AbstractBDBMessageStore() |
Modifier and Type | Method and Description |
---|---|
void |
addEventListener(EventListener eventListener,
Event... events) |
<T extends StorableMessageMetaData> |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
closeMessageStore, getStoreLocation, getStoreLocationAsFile, onDelete, openMessageStore
public void upgradeStoreStructure() throws StoreException
MessageStore
upgradeStoreStructure
in interface MessageStore
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.public <T extends StorableMessageMetaData> MessageHandle<T> addMessage(T metaData)
addMessage
in interface MessageStore
public long getNextMessageId()
getNextMessageId
in interface MessageStore
public boolean isPersistent()
MessageStore
isPersistent
in interface MessageStore
public Transaction newTransaction()
newTransaction
in interface MessageStore
public void addEventListener(EventListener eventListener, Event... events)
addEventListener
in interface MessageStore
public MessageStore.MessageStoreReader newMessageStoreReader()
newMessageStoreReader
in interface MessageStore
protected abstract void checkMessageStoreOpen()
protected abstract ConfiguredObject<?> getParent()
protected abstract EnvironmentFacade getEnvironmentFacade()
protected abstract long getPersistentSizeLowThreshold()
protected abstract long getPersistentSizeHighThreshold()
protected abstract org.slf4j.Logger getLogger()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.