public interface VirtualHostImpl<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>> extends StatisticsGatherer, EventLoggerProvider, VirtualHost<X,Q,E>
VirtualHost.Transaction, VirtualHost.TransactionalOperation| Modifier and Type | Field and Description |
|---|---|
static String |
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_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, TYPEgetDataDeliveryStatistics, getDataReceiptStatistics, getMessageDeliveryStatistics, getMessageReceiptStatistics, registerMessageDelivered, registerMessageReceived, resetStatisticsaddConnectionAssociationListener, 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, stopaddChangeListener, 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, setAttributesAsyncstatic final String DEFAULT_DLE_NAME_SUFFIX
String getName()
ConfiguredObjectgetName in interface ConfiguredObject<X extends VirtualHostImpl<X,Q,E>>MessageSource getAttainedMessageSource(String name)
Collection<Q> getQueues()
getQueues in interface VirtualHost<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>>int removeQueue(Q queue)
com.google.common.util.concurrent.ListenableFuture<Integer> removeQueueAsync(Q queue)
Q createQueue(Map<String,Object> arguments) throws QueueExistsException
createQueue in interface VirtualHost<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>>QueueExistsExceptionE createExchange(Map<String,Object> attributes) throws ExchangeExistsException, ReservedExchangeNameException, NoFactoryForTypeException
createExchange in interface VirtualHost<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>>ExchangeExistsExceptionReservedExchangeNameExceptionNoFactoryForTypeExceptionMessageDestination getAttainedMessageDestination(String name)
MessageDestination getDefaultDestination()
Collection<E> getExchanges()
getExchanges in interface VirtualHost<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>>DurableConfigurationStore getDurableConfigurationStore()
MessageStore getMessageStore()
getMessageStore in interface VirtualHost<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>>SecurityManager getSecurityManager()
void scheduleHouseKeepingTask(long period,
HouseKeepingTask task)
long getHouseKeepingTaskCount()
long getHouseKeepingCompletedTaskCount()
int getHouseKeepingPoolSize()
void setHouseKeepingPoolSize(int newSize)
int getHouseKeepingActiveCount()
DtxRegistry getDtxRegistry()
LinkRegistry getLinkRegistry(String remoteContainerId)
ScheduledFuture<?> scheduleTask(long delay, Runnable timeoutTask)
boolean getDefaultDeadLetterQueueEnabled()
EventLogger getEventLogger()
getEventLogger in interface EventLoggerProviderboolean authoriseCreateConnection(AMQPConnection<?> connection)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.