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_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
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
static final String DEFAULT_DLE_NAME_SUFFIX
String getName()
ConfiguredObject
getName
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<?>>
QueueExistsException
E 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<?>>
ExchangeExistsException
ReservedExchangeNameException
NoFactoryForTypeException
MessageDestination 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 EventLoggerProvider
boolean authoriseCreateConnection(AMQPConnection<?> connection)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.