public class BDBMessageStore extends AbstractBDBMessageStore
AbstractBDBMessageStore.BDBEnqueueRecord
MessageStore.MessageStoreReader
Constructor and Description |
---|
BDBMessageStore() |
BDBMessageStore(EnvironmentFacadeFactory environmentFacadeFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkMessageStoreOpen() |
void |
closeMessageStore()
Called to close and cleanup any resources used by the message store.
|
EnvironmentFacade |
getEnvironmentFacade() |
protected org.slf4j.Logger |
getLogger() |
protected ConfiguredObject<?> |
getParent() |
protected long |
getPersistentSizeHighThreshold() |
protected long |
getPersistentSizeLowThreshold() |
String |
getStoreLocation() |
File |
getStoreLocationAsFile() |
void |
onDelete(ConfiguredObject<?> parent) |
void |
openMessageStore(ConfiguredObject<?> parent)
Initializes and opens the message store.
|
addEventListener, addMessage, getNextMessageId, isPersistent, newMessageStoreReader, newTransaction, upgradeStoreStructure
public BDBMessageStore()
public BDBMessageStore(EnvironmentFacadeFactory environmentFacadeFactory)
public void openMessageStore(ConfiguredObject<?> parent)
MessageStore
parent
- parent objectpublic void closeMessageStore()
MessageStore
public void onDelete(ConfiguredObject<?> parent)
public EnvironmentFacade getEnvironmentFacade()
getEnvironmentFacade
in class AbstractBDBMessageStore
protected long getPersistentSizeLowThreshold()
getPersistentSizeLowThreshold
in class AbstractBDBMessageStore
protected long getPersistentSizeHighThreshold()
getPersistentSizeHighThreshold
in class AbstractBDBMessageStore
protected org.slf4j.Logger getLogger()
getLogger
in class AbstractBDBMessageStore
protected void checkMessageStoreOpen()
checkMessageStoreOpen
in class AbstractBDBMessageStore
protected ConfiguredObject<?> getParent()
getParent
in class AbstractBDBMessageStore
public String getStoreLocation()
public File getStoreLocationAsFile()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.