public class BDBHAReplicaVirtualHostImpl extends AbstractConfiguredObject<BDBHAReplicaVirtualHostImpl> implements BDBHAReplicaVirtualHost<BDBHAReplicaVirtualHostImpl>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
VirtualHost.Transaction, VirtualHost.TransactionalOperation
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 |
---|
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, validateOnCreate
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, 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
public 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 EventLoggerProvider
getEventLogger
in interface VirtualHostImpl<BDBHAReplicaVirtualHostImpl,AMQQueue<?>,ExchangeImpl<?>>
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 void registerMessageDelivered(long messageSize)
StatisticsGatherer
registerMessageDelivered
in interface StatisticsGatherer
messageSize
- the size in bytes of the delivered messageStatisticsGatherer.registerMessageReceived(long, long)
public StatisticsCounter getMessageDeliveryStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
delivered message statistics.getMessageDeliveryStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts delivered messagespublic StatisticsCounter getMessageReceiptStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
received message statistics.getMessageReceiptStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts received messagespublic StatisticsCounter getDataDeliveryStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
delivered message size statistics.getDataDeliveryStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts delivered bytespublic StatisticsCounter getDataReceiptStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
received message size statistics.getDataReceiptStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts received bytespublic void resetStatistics()
StatisticsGatherer
StatisticsGatherer
s.resetStatistics
in interface StatisticsGatherer
public 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.