public class ProvidedStoreVirtualHostImpl extends AbstractVirtualHost<ProvidedStoreVirtualHostImpl> implements ProvidedStoreVirtualHost<ProvidedStoreVirtualHostImpl>
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 |
STORE_PATH |
static String |
VIRTUAL_HOST_TYPE |
CREATE_DLQ_ON_CREATION, DEFAULT_DLQ_NAME_SUFFIX, DLQ_ROUTING_KEY
SECURED_STRING_VALUE
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 |
---|
ProvidedStoreVirtualHostImpl(Map<String,Object> attributes,
VirtualHostNode<?> virtualHostNode) |
Modifier and Type | Method and Description |
---|---|
protected MessageStore |
createMessageStore() |
Long |
getStoreOverfullSize() |
Long |
getStoreUnderfullSize() |
void |
onValidate()
Validation performed for configured object creation and opening.
|
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, 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 static final String STORE_PATH
public ProvidedStoreVirtualHostImpl(Map<String,Object> attributes, VirtualHostNode<?> virtualHostNode)
public void onValidate()
AbstractConfiguredObject
onValidate
in class AbstractVirtualHost<ProvidedStoreVirtualHostImpl>
protected MessageStore createMessageStore()
createMessageStore
in class AbstractVirtualHost<ProvidedStoreVirtualHostImpl>
public Long getStoreUnderfullSize()
getStoreUnderfullSize
in interface SizeMonitoringSettings
getStoreUnderfullSize
in interface ProvidedStoreVirtualHost<ProvidedStoreVirtualHostImpl>
public Long getStoreOverfullSize()
getStoreOverfullSize
in interface SizeMonitoringSettings
getStoreOverfullSize
in interface ProvidedStoreVirtualHost<ProvidedStoreVirtualHostImpl>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.