public class BDBVirtualHostImpl extends AbstractVirtualHost<BDBVirtualHostImpl> implements BDBVirtualHost<BDBVirtualHostImpl>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
VirtualHost.Transaction, VirtualHost.TransactionalOperation
Modifier and Type | Field and Description |
---|---|
static String |
VIRTUAL_HOST_TYPE |
CREATE_DLQ_ON_CREATION, DEFAULT_DLQ_NAME_SUFFIX, DLQ_ROUTING_KEY
SECURED_STRING_VALUE
BDB_MIN_CACHE_SIZE, DEFAULT_JE_CACHE_SIZE, QPID_BROKER_BDB_TOTAL_CACHE_SIZE, STORE_PATH
DEFAULT_DLE_NAME_SUFFIX
CLASS_DESCRIPTION, CONNECTION_THREAD_POOL_KEEP_ALIVE_TIMEOUT, CONNECTION_THREAD_POOL_SIZE, DEFAULT_AWAIT_ATTAINMENT_TIMEOUT, DEFAULT_CONNECTION_THREAD_POOL_KEEP_ALIVE_TIMEOUT, DEFAULT_DEAD_LETTER_QUEUE_ENABLED, DEFAULT_DISABLED_VALIDATORS, DEFAULT_ENABLED_VALIDATORS, DEFAULT_HOUSEKEEPING_CHECK_PERIOD, DEFAULT_HOUSEKEEPING_THREAD_COUNT, DEFAULT_STORE_TRANSACTION_IDLE_TIMEOUT_CLOSE, DEFAULT_STORE_TRANSACTION_IDLE_TIMEOUT_WARN, DEFAULT_STORE_TRANSACTION_OPEN_TIMEOUT_CLOSE, DEFAULT_STORE_TRANSACTION_OPEN_TIMEOUT_WARN, DEFAULT_VIRTUALHOST_CONNECTION_THREAD_POOL_NUMBER_OF_SELECTORS, DEFAULT_VIRTUALHOST_CONNECTION_THREAD_POOL_SIZE, DISABLED_CONNECTION_VALIDATORS, ENABLED_CONNECTION_VALIDATORS, GLOBAL_ADDRESS_DOMAINS, HOUSE_KEEPING_THREAD_COUNT, HOUSEKEEPING_CHECK_PERIOD, MODEL_VERSION, NUMBER_OF_SELECTORS, QUEUE_DEAD_LETTER_QUEUE_ENABLED, STORE_TRANSACTION_IDLE_TIMEOUT_CLOSE, STORE_TRANSACTION_IDLE_TIMEOUT_WARN, STORE_TRANSACTION_OPEN_TIMEOUT_CLOSE, STORE_TRANSACTION_OPEN_TIMEOUT_WARN, VIRTUALHOST_CONNECTION_THREAD_POOL_NUMBER_OF_SELECTORS, VIRTUALHOST_CONNECTION_THREAD_POOL_SIZE, VIRTUALHOST_WORK_DIR, VIRTUALHOST_WORK_DIR_VAR, VIRTUALHOST_WORK_DIR_VAR_EXPRESSION
CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE
Constructor and Description |
---|
BDBVirtualHostImpl(Map<String,Object> attributes,
VirtualHostNode<?> virtualHostNode) |
Modifier and Type | Method and Description |
---|---|
void |
checkpoint(boolean force) |
int |
cleanLog() |
protected MessageStore |
createMessageStore() |
Map<String,Object> |
databaseStatistics(String database,
boolean reset) |
Map<String,Map<String,Object>> |
environmentStatistics(boolean reset) |
Long |
getStoreOverfullSize() |
String |
getStorePath() |
Long |
getStoreUnderfullSize() |
void |
setBDBCacheSize(long cacheSize) |
Map<String,Object> |
transactionStatistics(boolean reset) |
void |
updateMutableConfig() |
addChildAsync, addConnectionAssociationListener, authoriseCreateConnection, beforeClose, closeConnections, createExchange, createQueue, deregisterConnection, deregisterConnectionAsync, doStop, event, executeTask, executeTransaction, getAliases, getAttainedExchange, getAttainedMessageDestination, getAttainedMessageSource, getAttainedQueue, getAttainedQueue, getBroker, getBytesIn, getBytesOut, getChildren, getConnection, getConnectionCount, getConnections, getConnectionThreadPoolSize, getDataDeliveryStatistics, getDataReceiptStatistics, getDefaultDeadLetterQueueEnabled, getDefaultDestination, getDisabledConnectionValidators, getDtxRegistry, getDurableConfigurationStore, getEnabledConnectionValidators, getEventLogger, getExchangeCount, getExchanges, getExchangeTypeNames, getGlobalAddressDomains, getHouseKeepingActiveCount, getHousekeepingCheckPeriod, getHouseKeepingCompletedTaskCount, getHouseKeepingPoolSize, getHouseKeepingTaskCount, getHousekeepingThreadCount, getLinkRegistry, getLocalAddress, getMessageDeliveryStatistics, getMessageReceiptStatistics, getMessagesIn, getMessagesOut, getMessageStore, getMessageStoreLogSubject, getModelVersion, getNumberOfSelectors, getPrincipal, getQueueCount, getQueues, getRedirectHost, getSecurityManager, getStoreTransactionIdleTimeoutClose, getStoreTransactionIdleTimeoutWarn, getStoreTransactionOpenTimeoutClose, getStoreTransactionOpenTimeoutWarn, getTargetSize, getTotalQueueDepthBytes, isQueue_deadLetterQueueEnabled, isStoreEmpty, listConnections, onClose, onExceptionInOpen, onOpen, onValidate, registerConnection, registerConnectionAsync, registerMessageDelivered, registerMessageReceived, removeConnectionAssociationListener, removeHouseKeepingTasks, removeQueue, removeQueueAsync, reportIfError, resetStatistics, scheduleHouseKeepingTask, scheduleTask, setHouseKeepingPoolSize, setTargetSize, shutdownHouseKeeping, startFileSystemSpaceChecking, validateChange, validateMessageStoreCreation, validateOnCreate
addChangeListener, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, changeAttribute, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleted, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onCreate, onResolve, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
authoriseCreateConnection, createExchange, createQueue, getAttainedExchange, getAttainedMessageDestination, getAttainedMessageSource, getAttainedQueue, getAttainedQueue, getDefaultDeadLetterQueueEnabled, getDefaultDestination, getDtxRegistry, getDurableConfigurationStore, getEventLogger, getExchanges, getHouseKeepingActiveCount, getHouseKeepingCompletedTaskCount, getHouseKeepingPoolSize, getHouseKeepingTaskCount, getLinkRegistry, getLocalAddress, getMessageStore, getName, getQueues, getSecurityManager, removeQueue, removeQueueAsync, scheduleHouseKeepingTask, scheduleTask, setHouseKeepingPoolSize
getDataDeliveryStatistics, getDataReceiptStatistics, getMessageDeliveryStatistics, getMessageReceiptStatistics, registerMessageDelivered, registerMessageReceived, resetStatistics
addConnectionAssociationListener, deregisterConnection, executeTask, executeTransaction, getAliases, getBroker, getBytesIn, getBytesOut, getConnection, getConnectionCount, getConnections, getConnectionThreadPoolSize, getDisabledConnectionValidators, getEnabledConnectionValidators, getExchangeCount, getExchangeTypeNames, getGlobalAddressDomains, getHousekeepingCheckPeriod, getHousekeepingThreadCount, getMessagesIn, getMessagesOut, getModelVersion, getNumberOfSelectors, getPrincipal, getQueueCount, getRedirectHost, getStoreTransactionIdleTimeoutClose, getStoreTransactionIdleTimeoutWarn, getStoreTransactionOpenTimeoutClose, getStoreTransactionOpenTimeoutWarn, getTargetSize, getTotalQueueDepthBytes, getType, isQueue_deadLetterQueueEnabled, listConnections, registerConnection, removeConnectionAssociationListener, setTargetSize, start, stop
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
public static final String VIRTUAL_HOST_TYPE
public BDBVirtualHostImpl(Map<String,Object> attributes, VirtualHostNode<?> virtualHostNode)
protected MessageStore createMessageStore()
createMessageStore
in class AbstractVirtualHost<BDBVirtualHostImpl>
public String getStorePath()
getStorePath
in interface FileBasedSettings
getStorePath
in interface BDBVirtualHost<BDBVirtualHostImpl>
public Long getStoreUnderfullSize()
getStoreUnderfullSize
in interface SizeMonitoringSettings
getStoreUnderfullSize
in interface BDBVirtualHost<BDBVirtualHostImpl>
public Long getStoreOverfullSize()
getStoreOverfullSize
in interface SizeMonitoringSettings
getStoreOverfullSize
in interface BDBVirtualHost<BDBVirtualHostImpl>
public void setBDBCacheSize(long cacheSize)
setBDBCacheSize
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
public void updateMutableConfig()
updateMutableConfig
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
public int cleanLog()
cleanLog
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
public void checkpoint(boolean force)
checkpoint
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
public Map<String,Map<String,Object>> environmentStatistics(boolean reset)
environmentStatistics
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
public Map<String,Object> transactionStatistics(boolean reset)
transactionStatistics
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
public Map<String,Object> databaseStatistics(String database, boolean reset)
databaseStatistics
in interface BDBEnvironmentContainer<BDBVirtualHostImpl>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.