public abstract class AbstractVirtualHost<X extends AbstractVirtualHost<X>> extends AbstractConfiguredObject<X> implements VirtualHostImpl<X,AMQQueue<?>,ExchangeImpl<?>>, EventListener
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameExceptionVirtualHost.Transaction, VirtualHost.TransactionalOperation| Modifier and Type | Field and Description |
|---|---|
static String |
CREATE_DLQ_ON_CREATION |
static String |
DEFAULT_DLQ_NAME_SUFFIX |
static String |
DLQ_ROUTING_KEY |
SECURED_STRING_VALUEDEFAULT_DLE_NAME_SUFFIXCLASS_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_EXPRESSIONCONTEXT, 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 |
|---|
AbstractVirtualHost(Map<String,Object> attributes,
VirtualHostNode<?> virtualHostNode) |
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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetNamegetType, start, stopaddChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, 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, setAttributesAsyncpublic static final String DEFAULT_DLQ_NAME_SUFFIX
public static final String DLQ_ROUTING_KEY
public static final String CREATE_DLQ_ON_CREATION
public AbstractVirtualHost(Map<String,Object> attributes, VirtualHostNode<?> virtualHostNode)
public void onValidate()
AbstractConfiguredObjectonValidate in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>protected void validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
validateChange in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>public MessageStore getMessageStore()
getMessageStore in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>getMessageStore in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void validateOnCreate()
validateOnCreate in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>protected void validateMessageStoreCreation()
protected void onExceptionInOpen(RuntimeException e)
AbstractConfiguredObjectThe method is not expected to throw any runtime exception.
onExceptionInOpen in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>e - open exceptionprotected void onOpen()
onOpen in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>protected abstract MessageStore createMessageStore()
protected boolean isStoreEmpty()
protected MessageStoreLogSubject getMessageStoreLogSubject()
public Collection<AMQPConnection<?>> getConnections()
getConnections in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public Collection<Map<String,Object>> listConnections()
listConnections in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public Connection<?> getConnection(String name)
getConnection in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public <C extends ConfiguredObject> Collection<C> getChildren(Class<C> clazz)
ConfiguredObjectgetChildren in interface ConfiguredObject<X extends AbstractVirtualHost<X>>getChildren in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>clazz - the class of the children to returnprotected <C extends ConfiguredObject> com.google.common.util.concurrent.ListenableFuture<C> addChildAsync(Class<C> childClass, Map<String,Object> attributes, ConfiguredObject... otherParents)
addChildAsync in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>public Collection<String> getExchangeTypeNames()
getExchangeTypeNames in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public EventLogger getEventLogger()
getEventLogger in interface EventLoggerProvidergetEventLogger in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public boolean authoriseCreateConnection(AMQPConnection<?> connection)
authoriseCreateConnection in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>protected void shutdownHouseKeeping()
protected void removeHouseKeepingTasks()
public void scheduleHouseKeepingTask(long period,
HouseKeepingTask task)
scheduleHouseKeepingTask in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>period - How often this task should run, in ms.task - The task to run.public ScheduledFuture<?> scheduleTask(long delay, Runnable task)
scheduleTask in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void executeTask(String name, Runnable task, AccessControlContext context)
executeTask in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getHouseKeepingTaskCount()
getHouseKeepingTaskCount in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getHouseKeepingCompletedTaskCount()
getHouseKeepingCompletedTaskCount in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public int getHouseKeepingPoolSize()
getHouseKeepingPoolSize in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void setHouseKeepingPoolSize(int newSize)
setHouseKeepingPoolSize in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public int getHouseKeepingActiveCount()
getHouseKeepingActiveCount in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public List<String> getEnabledConnectionValidators()
getEnabledConnectionValidators in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public List<String> getDisabledConnectionValidators()
getDisabledConnectionValidators in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public List<String> getGlobalAddressDomains()
getGlobalAddressDomains in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public AMQQueue<?> getAttainedQueue(String name)
getAttainedQueue in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public MessageSource getAttainedMessageSource(String name)
getAttainedMessageSource in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public AMQQueue<?> getAttainedQueue(UUID id)
getAttainedQueue in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public Broker<?> getBroker()
getBroker in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public Collection<AMQQueue<?>> getQueues()
getQueues in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>getQueues in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public int removeQueue(AMQQueue<?> queue)
removeQueue in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public com.google.common.util.concurrent.ListenableFuture<Integer> removeQueueAsync(AMQQueue<?> queue)
removeQueueAsync in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public AMQQueue<?> createQueue(Map<String,Object> attributes) throws QueueExistsException
createQueue in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>createQueue in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>QueueExistsExceptionpublic MessageDestination getAttainedMessageDestination(String name)
getAttainedMessageDestination in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public ExchangeImpl getAttainedExchange(String name)
getAttainedExchange in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public MessageDestination getDefaultDestination()
getDefaultDestination in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public Collection<ExchangeImpl<?>> getExchanges()
getExchanges in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>getExchanges in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public ExchangeImpl createExchange(Map<String,Object> attributes) throws ExchangeExistsException, ReservedExchangeNameException, NoFactoryForTypeException
createExchange in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>createExchange in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>ExchangeExistsExceptionReservedExchangeNameExceptionNoFactoryForTypeExceptionpublic String getLocalAddress(String routingAddress)
getLocalAddress in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public SecurityManager getSecurityManager()
getSecurityManager in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>getSecurityManager in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>protected com.google.common.util.concurrent.ListenableFuture<Void> beforeClose()
beforeClose in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>protected void onClose()
onClose in class AbstractConfiguredObject<X extends AbstractVirtualHost<X>>public com.google.common.util.concurrent.ListenableFuture<Void> closeConnections()
public void registerMessageDelivered(long messageSize)
StatisticsGathererregisterMessageDelivered in interface StatisticsGatherermessageSize - the size in bytes of the delivered messageStatisticsGatherer.registerMessageReceived(long, long)public void registerMessageReceived(long messageSize,
long timestamp)
StatisticsGathererStatisticsGatherers. If statistics generation is not enabled,
then this method should simple delegate to the parent gatherer.registerMessageReceived in interface StatisticsGatherermessageSize - the size in bytes of the delivered messagetimestamp - the time the message was deliveredpublic StatisticsCounter getMessageReceiptStatistics()
StatisticsGathererStatisticsCounter that is used to count
received message statistics.getMessageReceiptStatistics in interface StatisticsGathererStatisticsCounter that counts received messagespublic StatisticsCounter getDataReceiptStatistics()
StatisticsGathererStatisticsCounter that is used to count
received message size statistics.getDataReceiptStatistics in interface StatisticsGathererStatisticsCounter that counts received bytespublic StatisticsCounter getMessageDeliveryStatistics()
StatisticsGathererStatisticsCounter that is used to count
delivered message statistics.getMessageDeliveryStatistics in interface StatisticsGathererStatisticsCounter that counts delivered messagespublic StatisticsCounter getDataDeliveryStatistics()
StatisticsGathererStatisticsCounter that is used to count
delivered message size statistics.getDataDeliveryStatistics in interface StatisticsGathererStatisticsCounter that counts delivered bytespublic void resetStatistics()
StatisticsGathererStatisticsGatherers.resetStatistics in interface StatisticsGathererpublic LinkRegistry getLinkRegistry(String remoteContainerId)
getLinkRegistry in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public DtxRegistry getDtxRegistry()
getDtxRegistry in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void event(Event event)
event in interface EventListenerprotected void reportIfError(State state)
public String getRedirectHost(AmqpPort<?> port)
getRedirectHost in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public boolean getDefaultDeadLetterQueueEnabled()
getDefaultDeadLetterQueueEnabled in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void executeTransaction(VirtualHost.TransactionalOperation op)
executeTransaction in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public boolean isQueue_deadLetterQueueEnabled()
isQueue_deadLetterQueueEnabled in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getHousekeepingCheckPeriod()
getHousekeepingCheckPeriod in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionIdleTimeoutClose()
getStoreTransactionIdleTimeoutClose in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionIdleTimeoutWarn()
getStoreTransactionIdleTimeoutWarn in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionOpenTimeoutClose()
getStoreTransactionOpenTimeoutClose in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionOpenTimeoutWarn()
getStoreTransactionOpenTimeoutWarn in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getQueueCount()
getQueueCount in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getExchangeCount()
getExchangeCount in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getConnectionCount()
getConnectionCount in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getBytesIn()
getBytesIn in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getBytesOut()
getBytesOut in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getMessagesIn()
getMessagesIn in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getMessagesOut()
getMessagesOut in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public int getHousekeepingThreadCount()
getHousekeepingThreadCount in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public int getConnectionThreadPoolSize()
getConnectionThreadPoolSize in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public int getNumberOfSelectors()
getNumberOfSelectors in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>protected com.google.common.util.concurrent.ListenableFuture<Void> doStop()
public Collection<VirtualHostAlias> getAliases()
getAliases in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public String getModelVersion()
getModelVersion in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public DurableConfigurationStore getDurableConfigurationStore()
getDurableConfigurationStore in interface VirtualHostImpl<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void setTargetSize(long targetSize)
setTargetSize in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getTargetSize()
getTargetSize in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public long getTotalQueueDepthBytes()
getTotalQueueDepthBytes in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public Principal getPrincipal()
getPrincipal in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void registerConnection(AMQPConnection<?> connection)
registerConnection in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public com.google.common.util.concurrent.ListenableFuture<Void> registerConnectionAsync(AMQPConnection<?> connection)
public void deregisterConnection(AMQPConnection<?> connection)
deregisterConnection in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public com.google.common.util.concurrent.ListenableFuture<Void> deregisterConnectionAsync(AMQPConnection<?> connection)
protected void startFileSystemSpaceChecking()
public void addConnectionAssociationListener(VirtualHostConnectionListener listener)
addConnectionAssociationListener in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>public void removeConnectionAssociationListener(VirtualHostConnectionListener listener)
removeConnectionAssociationListener in interface VirtualHost<X extends AbstractVirtualHost<X>,AMQQueue<?>,ExchangeImpl<?>>Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.