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.DuplicateNameException
VirtualHost.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_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 |
---|
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, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName
getType, start, stop
addChangeListener, 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, setAttributesAsync
public 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()
AbstractConfiguredObject
onValidate
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)
AbstractConfiguredObject
The 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)
ConfiguredObject
getChildren
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 EventLoggerProvider
getEventLogger
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<?>>
QueueExistsException
public 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<?>>
ExchangeExistsException
ReservedExchangeNameException
NoFactoryForTypeException
public 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)
StatisticsGatherer
registerMessageDelivered
in interface StatisticsGatherer
messageSize
- the size in bytes of the delivered messageStatisticsGatherer.registerMessageReceived(long, long)
public void registerMessageReceived(long messageSize, long timestamp)
StatisticsGatherer
StatisticsGatherer
s. If statistics generation is not enabled,
then this method should simple delegate to the parent gatherer.registerMessageReceived
in interface StatisticsGatherer
messageSize
- the size in bytes of the delivered messagetimestamp
- the time the message was deliveredpublic StatisticsCounter getMessageReceiptStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
received message statistics.getMessageReceiptStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts received messagespublic StatisticsCounter getDataReceiptStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
received message size statistics.getDataReceiptStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts received bytespublic StatisticsCounter getMessageDeliveryStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
delivered message statistics.getMessageDeliveryStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts delivered messagespublic StatisticsCounter getDataDeliveryStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
delivered message size statistics.getDataDeliveryStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts delivered bytespublic void resetStatistics()
StatisticsGatherer
StatisticsGatherer
s.resetStatistics
in interface StatisticsGatherer
public 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 EventListener
protected 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.