public class BrokerAdapter extends AbstractConfiguredObject<BrokerAdapter> implements Broker<BrokerAdapter>, StatisticsGatherer
Modifier and Type | Class and Description |
---|---|
static class |
BrokerAdapter.ThreadStackContent |
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
Modifier and Type | Field and Description |
---|---|
static String |
MANAGEMENT_MODE_AUTHENTICATION |
SECURED_STRING_VALUE
BROKER_DIRECT_BYTE_BUFFER_POOL_SIZE, BROKER_FAIL_STARTUP_WITH_ERRORED_CHILD, BROKER_FLOW_TO_DISK_THRESHOLD, BROKER_MESSAGE_COMPRESSION_ENABLED, BROKER_MSG_AUTH, BUILD_VERSION, CHANNEL_FLOW_CONTROL_ENFORCEMENT_TIMEOUT, CONFIDENTIAL_CONFIGURATION_ENCRYPTION_PROVIDER, CONNECTION_CLOSE_WHEN_NO_ROUTE, CONNECTION_HEART_BEAT_DELAY, CONNECTION_SESSION_COUNT_LIMIT, DEFAULT_AMQP_PORT_NUMBER, DEFAULT_BROKER_DIRECT_BYTE_BUFFER_POOL_SIZE, DEFAULT_BROKER_FAIL_STARTUP_WITH_ERRORED_CHILD, DEFAULT_BROKER_MSG_AUTH, DEFAULT_BROKER_NAME, DEFAULT_CHANNEL_FLOW_CONTROL_ENFORCEMENT_TIMEOUT, DEFAULT_FILESYSTEM_MAX_USAGE_PERCENT, DEFAULT_FLOW_TO_DISK_THRESHOLD, DEFAULT_HTTP_PORT_NUMBER, DEFAULT_JMX_PORT_NUMBER, DEFAULT_MESSAGE_COMPRESSION_ENABLED, DEFAULT_MESSAGE_COMPRESSION_THRESHOLD_SIZE, DEFAULT_NETWORK_BUFFER_SIZE, DEFAULT_RMI_PORT_NUMBER, DEFAULT_SECURITY_TLS_CIPHER_SUITE_BLACK_LIST, DEFAULT_SECURITY_TLS_CIPHER_SUITE_WHITE_LIST, DEFAULT_SECURITY_TLS_PROTOCOL_BLACK_LIST, DEFAULT_SECURITY_TLS_PROTOCOL_WHITE_LIST, DEFAULT_SEND_QUEUE_DELETE_OK_REGARDLESS_CLIENT_VER_REGEXP, MESSAGE_COMPRESSION_THRESHOLD_SIZE, MINIMUM_NETWORK_BUFFER_SIZE, MODEL_VERSION, NETWORK_BUFFER_SIZE, OPERATING_SYSTEM, PLATFORM, PROCESS_PID, PRODUCT_VERSION, QPID_AMQP_PORT, QPID_HTTP_PORT, QPID_JMX_PORT, QPID_RMI_PORT, SEND_QUEUE_DELETE_OK_REGARDLESS_CLIENT_VER_REGEXP, STATISTICS_REPORTING_PERIOD, STATISTICS_REPORTING_RESET_ENABLED, STORE_FILESYSTEM_MAX_USAGE_PERCENT, STORE_PATH
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 |
---|
BrokerAdapter(Map<String,Object> attributes,
SystemConfig parent) |
addChangeListener, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, 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, onCreate, onResolve, open, openAsync, parentsMap, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString, validateOnCreate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
public static final String MANAGEMENT_MODE_AUTHENTICATION
public BrokerAdapter(Map<String,Object> attributes, SystemConfig parent)
protected void postResolve()
postResolve
in class AbstractConfiguredObject<BrokerAdapter>
protected void postResolveChildren()
postResolveChildren
in class AbstractConfiguredObject<BrokerAdapter>
public void onValidate()
AbstractConfiguredObject
onValidate
in class AbstractConfiguredObject<BrokerAdapter>
protected void validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
validateChange
in class AbstractConfiguredObject<BrokerAdapter>
public void initiateShutdown()
initiateShutdown
in interface Broker<BrokerAdapter>
public String getBuildVersion()
getBuildVersion
in interface Broker<BrokerAdapter>
public String getOperatingSystem()
getOperatingSystem
in interface Broker<BrokerAdapter>
public String getPlatform()
getPlatform
in interface Broker<BrokerAdapter>
public String getProcessPid()
getProcessPid
in interface Broker<BrokerAdapter>
public String getProductVersion()
getProductVersion
in interface Broker<BrokerAdapter>
public int getNumberOfCores()
getNumberOfCores
in interface Broker<BrokerAdapter>
public int getConnection_sessionCountLimit()
getConnection_sessionCountLimit
in interface Broker<BrokerAdapter>
public int getConnection_heartBeatDelay()
getConnection_heartBeatDelay
in interface Broker<BrokerAdapter>
public boolean getConnection_closeWhenNoRoute()
getConnection_closeWhenNoRoute
in interface Broker<BrokerAdapter>
public int getStatisticsReportingPeriod()
getStatisticsReportingPeriod
in interface Broker<BrokerAdapter>
public boolean getStatisticsReportingResetEnabled()
getStatisticsReportingResetEnabled
in interface Broker<BrokerAdapter>
public boolean isMessageCompressionEnabled()
isMessageCompressionEnabled
in interface Broker<BrokerAdapter>
public String getConfidentialConfigurationEncryptionProvider()
getConfidentialConfigurationEncryptionProvider
in interface Broker<BrokerAdapter>
public String getModelVersion()
getModelVersion
in interface Broker<BrokerAdapter>
public Collection<VirtualHostNode<?>> getVirtualHostNodes()
getVirtualHostNodes
in interface Broker<BrokerAdapter>
public Collection<Port<?>> getPorts()
getPorts
in interface Broker<BrokerAdapter>
public Collection<AuthenticationProvider<?>> getAuthenticationProviders()
getAuthenticationProviders
in interface Broker<BrokerAdapter>
public void assignTargetSizes()
assignTargetSizes
in interface Broker<BrokerAdapter>
protected void onOpen()
onOpen
in class AbstractConfiguredObject<BrokerAdapter>
public Collection<GroupProvider<?>> getGroupProviders()
getGroupProviders
in interface Broker<BrokerAdapter>
public long getBytesIn()
getBytesIn
in interface Broker<BrokerAdapter>
public long getBytesOut()
getBytesOut
in interface Broker<BrokerAdapter>
public long getMessagesIn()
getMessagesIn
in interface Broker<BrokerAdapter>
public long getMessagesOut()
getMessagesOut
in interface Broker<BrokerAdapter>
public <C extends ConfiguredObject> com.google.common.util.concurrent.ListenableFuture<C> addChildAsync(Class<C> childClass, Map<String,Object> attributes, ConfiguredObject... otherParents)
addChildAsync
in class AbstractConfiguredObject<BrokerAdapter>
protected com.google.common.util.concurrent.ListenableFuture<Void> beforeClose()
beforeClose
in class AbstractConfiguredObject<BrokerAdapter>
protected void onClose()
onClose
in class AbstractConfiguredObject<BrokerAdapter>
public SecurityManager getSecurityManager()
Broker
getSecurityManager
in interface Broker<BrokerAdapter>
getSecurityManager
in class AbstractConfiguredObject<BrokerAdapter>
public VirtualHost<?,?,?> findVirtualHostByName(String name)
findVirtualHostByName
in interface Broker<BrokerAdapter>
public VirtualHostNode findDefautVirtualHostNode()
findDefautVirtualHostNode
in interface Broker<BrokerAdapter>
public Collection<KeyStore<?>> getKeyStores()
getKeyStores
in interface Broker<BrokerAdapter>
public Collection<TrustStore<?>> getTrustStores()
getTrustStores
in interface Broker<BrokerAdapter>
public boolean isManagementMode()
isManagementMode
in interface Broker<BrokerAdapter>
public Collection<AccessControlProvider<?>> getAccessControlProviders()
getAccessControlProviders
in interface Broker<BrokerAdapter>
public EventLogger getEventLogger()
getEventLogger
in interface EventLoggerProvider
getEventLogger
in interface Broker<BrokerAdapter>
public void setEventLogger(EventLogger eventLogger)
setEventLogger
in interface Broker<BrokerAdapter>
protected void onExceptionInOpen(RuntimeException e)
AbstractConfiguredObject
The method is not expected to throw any runtime exception.
onExceptionInOpen
in class AbstractConfiguredObject<BrokerAdapter>
e
- open exceptionpublic void registerMessageDelivered(long messageSize)
StatisticsGatherer
registerMessageDelivered
in interface StatisticsGatherer
messageSize
- the size in bytes of the delivered messageStatisticsGatherer.registerMessageReceived(long, long)
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 StatisticsCounter getMessageReceiptStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
received message statistics.getMessageReceiptStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts received messagespublic StatisticsCounter getDataReceiptStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
received message size statistics.getDataReceiptStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts received bytespublic StatisticsCounter getMessageDeliveryStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
delivered message statistics.getMessageDeliveryStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts delivered messagespublic StatisticsCounter getDataDeliveryStatistics()
StatisticsGatherer
StatisticsCounter
that is used to count
delivered message size statistics.getDataDeliveryStatistics
in interface StatisticsGatherer
StatisticsCounter
that counts delivered bytespublic void resetStatistics()
StatisticsGatherer
StatisticsGatherer
s.resetStatistics
in interface StatisticsGatherer
public boolean isVirtualHostPropertiesNodeEnabled()
isVirtualHostPropertiesNodeEnabled
in interface Broker<BrokerAdapter>
public AuthenticationProvider<?> getManagementModeAuthenticationProvider()
getManagementModeAuthenticationProvider
in interface Broker<BrokerAdapter>
public static Collection<String> getAvailableConfigurationEncrypters()
public static long getMaxDirectMemorySize()
public int getNetworkBufferSize()
getNetworkBufferSize
in interface Broker<BrokerAdapter>
public int getNumberOfLiveThreads()
getNumberOfLiveThreads
in interface Broker<BrokerAdapter>
public long getMaximumHeapMemorySize()
getMaximumHeapMemorySize
in interface Broker<BrokerAdapter>
public long getUsedHeapMemorySize()
getUsedHeapMemorySize
in interface Broker<BrokerAdapter>
public long getMaximumDirectMemorySize()
getMaximumDirectMemorySize
in interface Broker<BrokerAdapter>
public long getUsedDirectMemorySize()
getUsedDirectMemorySize
in interface Broker<BrokerAdapter>
public long getDirectMemoryTotalCapacity()
getDirectMemoryTotalCapacity
in interface Broker<BrokerAdapter>
public int getNumberOfObjectsPendingFinalization()
getNumberOfObjectsPendingFinalization
in interface Broker<BrokerAdapter>
public List<String> getJvmArguments()
getJvmArguments
in interface Broker<BrokerAdapter>
public void performGC()
performGC
in interface Broker<BrokerAdapter>
public Content getThreadStackTraces(boolean appendToLog)
getThreadStackTraces
in interface Broker<BrokerAdapter>
public Content findThreadStackTraces(String threadNameFindExpression)
findThreadStackTraces
in interface Broker<BrokerAdapter>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.