public class AmqpPortImpl extends AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl> implements AmqpPort<AmqpPortImpl>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BINDING_ADDRESS |
DEFAULT_AMQP_NEED_CLIENT_AUTH, DEFAULT_AMQP_WANT_CLIENT_AUTH
SECURED_STRING_VALUE
DEFAULT_AMQP_NEED_CLIENT_AUTH, DEFAULT_AMQP_PROTOCOLS, DEFAULT_AMQP_TCP_NO_DELAY, DEFAULT_AMQP_WANT_CLIENT_AUTH, DEFAULT_MAX_MESSAGE_SIZE, DEFAULT_MAX_OPEN_CONNECTIONS, DEFAULT_OPEN_CONNECTIONS_WARN_PERCENT, DEFAULT_PORT_AMQP_ACCEPT_BACKLOG, DEFAULT_PORT_AMQP_NUMBER_OF_SELECTORS, DEFAULT_PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE, DEFAULT_PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT, DEFAULT_PORT_AMQP_THREAD_POOL_SIZE, DEFAULT_PROTOCOL_HANDSHAKE_TIMEOUT, INSTALLED_PROTOCOLS, MAX_OPEN_CONNECTIONS, NUMBER_OF_SELECTORS, OPEN_CONNECTIONS_WARN_PERCENT, PORT_AMQP_ACCEPT_BACKLOG, PORT_AMQP_NUMBER_OF_SELECTORS, PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE, PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT, PORT_AMQP_THREAD_POOL_SIZE, PORT_MAX_MESSAGE_SIZE, PORT_MAX_OPEN_CONNECTIONS, PROTOCOL_HANDSHAKE_TIMEOUT, THREAD_POOL_SIZE
AUTHENTICATION_PROVIDER, BINDING_ADDRESS, CLASS_DESCRIPTION, CONNECTION_MAXIMUM_AUTHENTICATION_DELAY, DEFAULT_MAX_CONNECTION_AUTHENTICATION_DELAY, KEY_STORE, NEED_CLIENT_AUTH, PORT, PROTOCOLS, TCP_NO_DELAY, TRANSPORTS, TRUST_STORES, WANT_CLIENT_AUTH
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 |
---|
AmqpPortImpl(Map<String,Object> attributes,
Broker<?> broker) |
getClientCertRecorder, getNeedClientAuth, getWantClientAuth
getAuthenticationProvider
activate, getConnections, getKeyStore, getPort, getProtocols, getTlsCipherSuiteBlackList, getTlsCipherSuiteWhiteList, getTlsProtocolBlackList, getTlsProtocolWhiteList, getTransports, getTrustStores, hasNonTLSTransport, hasNonTLSTransport, isUsingTLSTransport, isUsingTLSTransport, toString, validateOnlyOneInstance
addChangeListener, addChildAsync, 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, getSecurityManager, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onExceptionInOpen, onResolve, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getAuthenticationProvider, getClientCertRecorder, getNeedClientAuth, getProtocols, getTransports, getWantClientAuth
getConnections, getKeyStore, getPort, getTlsCipherSuiteBlackList, getTlsCipherSuiteWhiteList, getTlsProtocolBlackList, getTlsProtocolWhiteList, getTrustStores, start, startAsync
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 DEFAULT_BINDING_ADDRESS
public int getThreadPoolSize()
getThreadPoolSize
in interface AmqpPort<AmqpPortImpl>
public int getNumberOfSelectors()
getNumberOfSelectors
in interface AmqpPort<AmqpPortImpl>
public SSLContext getSSLContext()
getSSLContext
in interface AmqpPort<AmqpPortImpl>
public String getBindingAddress()
getBindingAddress
in interface AmqpPort<AmqpPortImpl>
public boolean isTcpNoDelay()
isTcpNoDelay
in interface AmqpPort<AmqpPortImpl>
public int getMaxOpenConnections()
getMaxOpenConnections
in interface AmqpPort<AmqpPortImpl>
protected void onCreate()
onCreate
in class AbstractConfiguredObject<AmqpPortImpl>
protected void onOpen()
onOpen
in class AbstractPort<AmqpPortImpl>
public VirtualHostImpl getVirtualHost(String name)
getVirtualHost
in interface AmqpPort<AmqpPortImpl>
protected State onActivate()
onActivate
in class AbstractPort<AmqpPortImpl>
protected com.google.common.util.concurrent.ListenableFuture<Void> beforeClose()
beforeClose
in class AbstractConfiguredObject<AmqpPortImpl>
protected void onClose()
onClose
in class AbstractConfiguredObject<AmqpPortImpl>
public VirtualHostAlias createVirtualHostAlias(Map<String,Object> attributes)
createVirtualHostAlias
in interface AmqpPort<AmqpPortImpl>
public int getNetworkBufferSize()
getNetworkBufferSize
in interface AmqpPort<AmqpPortImpl>
public void validateOnCreate()
validateOnCreate
in class AbstractConfiguredObject<AmqpPortImpl>
public void onValidate()
AbstractConfiguredObject
onValidate
in class AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl>
protected void validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
validateChange
in class AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl>
public static Collection<String> getAllAvailableProtocolCombinations()
public static Collection<String> getAllAvailableTransportCombinations()
public static String getInstalledProtocolsAsString()
public int incrementConnectionCount()
incrementConnectionCount
in interface AmqpPort<AmqpPortImpl>
public int decrementConnectionCount()
decrementConnectionCount
in interface AmqpPort<AmqpPortImpl>
public boolean canAcceptNewConnection(SocketAddress remoteSocketAddress)
canAcceptNewConnection
in interface AmqpPort<AmqpPortImpl>
public int getConnectionCount()
getConnectionCount
in interface AmqpPort<AmqpPortImpl>
public long getProtocolHandshakeTimeout()
getProtocolHandshakeTimeout
in interface AmqpPort<AmqpPortImpl>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.