public interface VirtualHost<X extends VirtualHost<X,Q,E>,Q extends Queue<?>,E extends Exchange<?>> extends ConfiguredObject<X>
Modifier and Type | Interface and Description |
---|---|
static interface |
VirtualHost.Transaction |
static interface |
VirtualHost.TransactionalOperation |
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
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, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
static final String CLASS_DESCRIPTION
static final String QUEUE_DEAD_LETTER_QUEUE_ENABLED
static final String HOUSEKEEPING_CHECK_PERIOD
static final String STORE_TRANSACTION_IDLE_TIMEOUT_CLOSE
static final String STORE_TRANSACTION_IDLE_TIMEOUT_WARN
static final String STORE_TRANSACTION_OPEN_TIMEOUT_CLOSE
static final String STORE_TRANSACTION_OPEN_TIMEOUT_WARN
static final String HOUSE_KEEPING_THREAD_COUNT
static final String MODEL_VERSION
static final String ENABLED_CONNECTION_VALIDATORS
static final String DISABLED_CONNECTION_VALIDATORS
static final String GLOBAL_ADDRESS_DOMAINS
static final String VIRTUALHOST_WORK_DIR_VAR
static final String VIRTUALHOST_WORK_DIR_VAR_EXPRESSION
static final String NUMBER_OF_SELECTORS
static final String CONNECTION_THREAD_POOL_SIZE
static final String CONNECTION_THREAD_POOL_KEEP_ALIVE_TIMEOUT
static final String VIRTUALHOST_WORK_DIR
static final boolean DEFAULT_DEAD_LETTER_QUEUE_ENABLED
static final long DEFAULT_HOUSEKEEPING_CHECK_PERIOD
static final long DEFAULT_CONNECTION_THREAD_POOL_KEEP_ALIVE_TIMEOUT
static final long DEFAULT_STORE_TRANSACTION_IDLE_TIMEOUT_CLOSE
static final long DEFAULT_STORE_TRANSACTION_IDLE_TIMEOUT_WARN
static final long DEFAULT_STORE_TRANSACTION_OPEN_TIMEOUT_CLOSE
static final long DEFAULT_STORE_TRANSACTION_OPEN_TIMEOUT_WARN
static final int DEFAULT_HOUSEKEEPING_THREAD_COUNT
static final String VIRTUALHOST_CONNECTION_THREAD_POOL_SIZE
static final long DEFAULT_VIRTUALHOST_CONNECTION_THREAD_POOL_SIZE
static final String VIRTUALHOST_CONNECTION_THREAD_POOL_NUMBER_OF_SELECTORS
static final long DEFAULT_VIRTUALHOST_CONNECTION_THREAD_POOL_NUMBER_OF_SELECTORS
static final int DEFAULT_AWAIT_ATTAINMENT_TIMEOUT
static final String DEFAULT_ENABLED_VALIDATORS
static final String DEFAULT_DISABLED_VALIDATORS
boolean isQueue_deadLetterQueueEnabled()
long getHousekeepingCheckPeriod()
long getStoreTransactionIdleTimeoutClose()
long getStoreTransactionIdleTimeoutWarn()
long getStoreTransactionOpenTimeoutClose()
long getStoreTransactionOpenTimeoutWarn()
int getHousekeepingThreadCount()
int getConnectionThreadPoolSize()
int getNumberOfSelectors()
String getModelVersion()
void executeTask(String name, Runnable task, AccessControlContext context)
long getQueueCount()
long getExchangeCount()
long getConnectionCount()
long getBytesIn()
long getBytesOut()
long getMessagesIn()
long getMessagesOut()
Broker<?> getBroker()
Collection<VirtualHostAlias> getAliases()
Collection<Q> getQueues()
Collection<E> getExchanges()
E createExchange(Map<String,Object> attributes) throws AccessControlException, IllegalArgumentException
Q createQueue(Map<String,Object> attributes) throws AccessControlException, IllegalArgumentException
Collection<String> getExchangeTypeNames()
Collection<? extends Connection<?>> getConnections()
Collection<Map<String,Object>> listConnections()
Connection<?> getConnection(String name)
void start()
void stop()
Principal getPrincipal()
void registerConnection(AMQPConnection<?> connection)
void deregisterConnection(AMQPConnection<?> connection)
void executeTransaction(VirtualHost.TransactionalOperation op)
MessageStore getMessageStore()
String getType()
getType
in interface ConfiguredObject<X extends VirtualHost<X,Q,E>>
void setTargetSize(long targetSize)
long getTargetSize()
long getTotalQueueDepthBytes()
void addConnectionAssociationListener(VirtualHostConnectionListener listener)
void removeConnectionAssociationListener(VirtualHostConnectionListener listener)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.