public class BDBHAReplicaVirtualHostImpl extends AbstractConfiguredObject<BDBHAReplicaVirtualHostImpl> implements BDBHAReplicaVirtualHost<BDBHAReplicaVirtualHostImpl>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameExceptionVirtualHost.Transaction, VirtualHost.TransactionalOperationSECURED_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 |
|---|
BDBHAReplicaVirtualHostImpl(Map<String,Object> attributes,
VirtualHostNode<?> virtualHostNode) |
addChangeListener, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, beforeClose, 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, getChildren, 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, onClose, onCreate, onExceptionInOpen, onOpen, onResolve, onValidate, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString, validateOnCreateclone, 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, 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, setAttributesAsyncpublic BDBHAReplicaVirtualHostImpl(Map<String,Object> attributes, VirtualHostNode<?> virtualHostNode)
protected void validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
validateChange in class AbstractConfiguredObject<BDBHAReplicaVirtualHostImpl>public String getModelVersion()
getModelVersion in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void executeTask(String name, Runnable task, AccessControlContext context)
executeTask in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Broker<?> getBroker()
getBroker in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>protected <C extends ConfiguredObject> com.google.common.util.concurrent.ListenableFuture<C> addChildAsync(Class<C> childClass, Map<String,Object> attributes, ConfiguredObject... otherParents)
addChildAsync in class AbstractConfiguredObject<BDBHAReplicaVirtualHostImpl>public ExchangeImpl createExchange(Map<String,Object> attributes)
createExchange in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>createExchange in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public MessageDestination getAttainedMessageDestination(String name)
getAttainedMessageDestination in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public ExchangeImpl<?> getAttainedExchange(String name)
getAttainedExchange in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public AMQQueue<?> createQueue(Map<String,Object> attributes)
createQueue in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>createQueue in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void executeTransaction(VirtualHost.TransactionalOperation op)
executeTransaction in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Collection<String> getExchangeTypeNames()
getExchangeTypeNames in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public String getRedirectHost(AmqpPort<?> port)
getRedirectHost in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public boolean isQueue_deadLetterQueueEnabled()
isQueue_deadLetterQueueEnabled in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getHousekeepingCheckPeriod()
getHousekeepingCheckPeriod in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionIdleTimeoutClose()
getStoreTransactionIdleTimeoutClose in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionIdleTimeoutWarn()
getStoreTransactionIdleTimeoutWarn in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionOpenTimeoutClose()
getStoreTransactionOpenTimeoutClose in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getStoreTransactionOpenTimeoutWarn()
getStoreTransactionOpenTimeoutWarn in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public int getHousekeepingThreadCount()
getHousekeepingThreadCount in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public int getConnectionThreadPoolSize()
getConnectionThreadPoolSize in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public int getNumberOfSelectors()
getNumberOfSelectors in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getQueueCount()
getQueueCount in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getExchangeCount()
getExchangeCount in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getConnectionCount()
getConnectionCount in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getBytesIn()
getBytesIn in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getBytesOut()
getBytesOut in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getMessagesIn()
getMessagesIn in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getMessagesOut()
getMessagesOut in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Collection<VirtualHostAlias> getAliases()
getAliases in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Collection<Connection<?>> getConnections()
getConnections in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Collection<Map<String,Object>> listConnections()
listConnections in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Connection<?> getConnection(String name)
getConnection in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public AMQQueue<?> getAttainedQueue(String name)
getAttainedQueue in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public MessageSource getAttainedMessageSource(String name)
getAttainedMessageSource in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public AMQQueue<?> getAttainedQueue(UUID id)
getAttainedQueue in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Collection<AMQQueue<?>> getQueues()
getQueues in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>getQueues in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public com.google.common.util.concurrent.ListenableFuture<Integer> removeQueueAsync(AMQQueue<?> queue)
removeQueueAsync in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public int removeQueue(AMQQueue<?> queue)
removeQueue in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Collection<ExchangeImpl<?>> getExchanges()
getExchanges in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>getExchanges in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public DurableConfigurationStore getDurableConfigurationStore()
getDurableConfigurationStore in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public MessageDestination getDefaultDestination()
getDefaultDestination in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public MessageStore getMessageStore()
getMessageStore in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>getMessageStore in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void setTargetSize(long targetSize)
setTargetSize in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getTargetSize()
getTargetSize in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getTotalQueueDepthBytes()
getTotalQueueDepthBytes in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public SecurityManager getSecurityManager()
getSecurityManager in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>getSecurityManager in class AbstractConfiguredObject<BDBHAReplicaVirtualHostImpl>public void scheduleHouseKeepingTask(long period,
HouseKeepingTask task)
scheduleHouseKeepingTask in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getHouseKeepingTaskCount()
getHouseKeepingTaskCount in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public long getHouseKeepingCompletedTaskCount()
getHouseKeepingCompletedTaskCount in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public int getHouseKeepingPoolSize()
getHouseKeepingPoolSize in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void setHouseKeepingPoolSize(int newSize)
setHouseKeepingPoolSize in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public int getHouseKeepingActiveCount()
getHouseKeepingActiveCount in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public DtxRegistry getDtxRegistry()
getDtxRegistry in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public LinkRegistry getLinkRegistry(String remoteContainerId)
getLinkRegistry in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public ScheduledFuture<?> scheduleTask(long delay, Runnable timeoutTask)
scheduleTask in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public boolean getDefaultDeadLetterQueueEnabled()
getDefaultDeadLetterQueueEnabled in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public EventLogger getEventLogger()
getEventLogger in interface EventLoggerProvidergetEventLogger in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>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 void registerMessageDelivered(long messageSize)
StatisticsGathererregisterMessageDelivered in interface StatisticsGatherermessageSize - the size in bytes of the delivered messageStatisticsGatherer.registerMessageReceived(long, long)public StatisticsCounter getMessageDeliveryStatistics()
StatisticsGathererStatisticsCounter that is used to count
delivered message statistics.getMessageDeliveryStatistics in interface StatisticsGathererStatisticsCounter that counts delivered messagespublic StatisticsCounter getMessageReceiptStatistics()
StatisticsGathererStatisticsCounter that is used to count
received message statistics.getMessageReceiptStatistics in interface StatisticsGathererStatisticsCounter that counts received messagespublic StatisticsCounter getDataDeliveryStatistics()
StatisticsGathererStatisticsCounter that is used to count
delivered message size statistics.getDataDeliveryStatistics in interface StatisticsGathererStatisticsCounter that counts delivered bytespublic StatisticsCounter getDataReceiptStatistics()
StatisticsGathererStatisticsCounter that is used to count
received message size statistics.getDataReceiptStatistics in interface StatisticsGathererStatisticsCounter that counts received bytespublic void resetStatistics()
StatisticsGathererStatisticsGatherers.resetStatistics in interface StatisticsGathererpublic boolean authoriseCreateConnection(AMQPConnection<?> connection)
authoriseCreateConnection in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public List<String> getEnabledConnectionValidators()
getEnabledConnectionValidators in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public List<String> getDisabledConnectionValidators()
getDisabledConnectionValidators in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public List<String> getGlobalAddressDomains()
getGlobalAddressDomains in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public String getLocalAddress(String routingAddress)
getLocalAddress in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public Principal getPrincipal()
getPrincipal in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void registerConnection(AMQPConnection<?> connection)
registerConnection in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void deregisterConnection(AMQPConnection<?> connection)
deregisterConnection in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void addConnectionAssociationListener(VirtualHostConnectionListener listener)
addConnectionAssociationListener in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>public void removeConnectionAssociationListener(VirtualHostConnectionListener listener)
removeConnectionAssociationListener in interface VirtualHost<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.