org.apache.qpid.server.model.port

Class AmqpPortImpl

java.lang.Object

org.apache.qpid.server.model.AbstractConfiguredObject<X>

org.apache.qpid.server.model.port.AbstractPort<X>

org.apache.qpid.server.model.port.AbstractPortWithAuthProvider<X>

org.apache.qpid.server.model.port.AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl>

org.apache.qpid.server.model.port.AmqpPortImpl

All Implemented Interfaces:

ConfiguredObject<AmqpPortImpl>, Port<AmqpPortImpl>, AmqpPort<AmqpPortImpl>, ClientAuthCapablePort<AmqpPortImpl>, PortWithAuthProvider<AmqpPortImpl>

public class AmqpPortImpl
extends AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl>
implements AmqpPort<AmqpPortImpl>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_BINDING_ADDRESS

Fields inherited from class org.apache.qpid.server.model.port.AbstractClientAuthCapablePortWithAuthProvider

DEFAULT_AMQP_NEED_CLIENT_AUTH, DEFAULT_AMQP_WANT_CLIENT_AUTH

Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

SECURED_STRING_VALUE

Fields inherited from interface org.apache.qpid.server.model.port.AmqpPort

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

Fields inherited from interface org.apache.qpid.server.model.Port

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

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

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 Summary

Constructors

Constructor and Description
AmqpPortImpl(Map<String,Object> attributes, Broker<?> broker)

Method Summary

Modifier and Type	Method and Description
protected com.google.common.util.concurrent.ListenableFuture<Void>	beforeClose()
boolean	canAcceptNewConnection(SocketAddress remoteSocketAddress)
VirtualHostAlias	createVirtualHostAlias(Map<String,Object> attributes)
int	decrementConnectionCount()
static Collection<String>	getAllAvailableProtocolCombinations()
static Collection<String>	getAllAvailableTransportCombinations()
String	getBindingAddress()
int	getConnectionCount()
static Set<Protocol>	getInstalledProtocols()
static String	getInstalledProtocolsAsString()
int	getMaxOpenConnections()
int	getNetworkBufferSize()
int	getNumberOfSelectors()
long	getProtocolHandshakeTimeout()
SSLContext	getSSLContext()
int	getThreadPoolSize()
VirtualHostImpl	getVirtualHost(String name)
int	incrementConnectionCount()
boolean	isTcpNoDelay()
protected State	onActivate()
protected void	onClose()
protected void	onCreate()
protected void	onOpen()
void	onValidate() Validation performed for configured object creation and opening.
protected void	validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
void	validateOnCreate()

Methods inherited from class org.apache.qpid.server.model.port.AbstractClientAuthCapablePortWithAuthProvider

getClientCertRecorder, getNeedClientAuth, getWantClientAuth

Methods inherited from class org.apache.qpid.server.model.port.AbstractPortWithAuthProvider

getAuthenticationProvider

Methods inherited from class org.apache.qpid.server.model.port.AbstractPort

activate, getConnections, getKeyStore, getPort, getProtocols, getTlsCipherSuiteBlackList, getTlsCipherSuiteWhiteList, getTlsProtocolBlackList, getTlsProtocolWhiteList, getTransports, getTrustStores, hasNonTLSTransport, hasNonTLSTransport, isUsingTLSTransport, isUsingTLSTransport, toString, validateOnlyOneInstance

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.server.model.port.AmqpPort

getAuthenticationProvider, getClientCertRecorder, getNeedClientAuth, getProtocols, getTransports, getWantClientAuth

Methods inherited from interface org.apache.qpid.server.model.Port

getConnections, getKeyStore, getPort, getTlsCipherSuiteBlackList, getTlsCipherSuiteWhiteList, getTlsProtocolBlackList, getTlsProtocolWhiteList, getTrustStores, start, startAsync

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

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

Field Detail

DEFAULT_BINDING_ADDRESS

public static final String DEFAULT_BINDING_ADDRESS

See Also:

Constant Field Values

Constructor Detail

AmqpPortImpl

public AmqpPortImpl(Map<String,Object> attributes,
                    Broker<?> broker)

Method Detail

getThreadPoolSize

public int getThreadPoolSize()

Specified by:

getThreadPoolSize in interface AmqpPort<AmqpPortImpl>

getNumberOfSelectors

public int getNumberOfSelectors()

Specified by:

getNumberOfSelectors in interface AmqpPort<AmqpPortImpl>

getSSLContext

public SSLContext getSSLContext()

Specified by:

getSSLContext in interface AmqpPort<AmqpPortImpl>

getBindingAddress

public String getBindingAddress()

Specified by:

getBindingAddress in interface AmqpPort<AmqpPortImpl>

isTcpNoDelay

public boolean isTcpNoDelay()

Specified by:

isTcpNoDelay in interface AmqpPort<AmqpPortImpl>

getMaxOpenConnections

public int getMaxOpenConnections()

Specified by:

getMaxOpenConnections in interface AmqpPort<AmqpPortImpl>

onCreate

protected void onCreate()

Overrides:

onCreate in class AbstractConfiguredObject<AmqpPortImpl>

onOpen

protected void onOpen()

Overrides:

onOpen in class AbstractPort<AmqpPortImpl>

getVirtualHost

public VirtualHostImpl getVirtualHost(String name)

Specified by:

getVirtualHost in interface AmqpPort<AmqpPortImpl>

onActivate

protected State onActivate()

Overrides:

onActivate in class AbstractPort<AmqpPortImpl>

beforeClose

protected com.google.common.util.concurrent.ListenableFuture<Void> beforeClose()

Overrides:

beforeClose in class AbstractConfiguredObject<AmqpPortImpl>

onClose

protected void onClose()

Overrides:

onClose in class AbstractConfiguredObject<AmqpPortImpl>

createVirtualHostAlias

public VirtualHostAlias createVirtualHostAlias(Map<String,Object> attributes)

Specified by:

createVirtualHostAlias in interface AmqpPort<AmqpPortImpl>

getNetworkBufferSize

public int getNetworkBufferSize()

Specified by:

getNetworkBufferSize in interface AmqpPort<AmqpPortImpl>

validateOnCreate

public void validateOnCreate()

Overrides:

validateOnCreate in class AbstractConfiguredObject<AmqpPortImpl>

onValidate

public void onValidate()

Description copied from class: AbstractConfiguredObject

Validation performed for configured object creation and opening.

Overrides:

onValidate in class AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl>

validateChange

protected void validateChange(ConfiguredObject<?> proxyForValidation,
                              Set<String> changedAttributes)

Overrides:

validateChange in class AbstractClientAuthCapablePortWithAuthProvider<AmqpPortImpl>

getInstalledProtocols

public static Set<Protocol> getInstalledProtocols()

getAllAvailableProtocolCombinations

public static Collection<String> getAllAvailableProtocolCombinations()

getAllAvailableTransportCombinations

public static Collection<String> getAllAvailableTransportCombinations()

getInstalledProtocolsAsString

public static String getInstalledProtocolsAsString()

incrementConnectionCount

public int incrementConnectionCount()

Specified by:

incrementConnectionCount in interface AmqpPort<AmqpPortImpl>

decrementConnectionCount

public int decrementConnectionCount()

Specified by:

decrementConnectionCount in interface AmqpPort<AmqpPortImpl>

canAcceptNewConnection

public boolean canAcceptNewConnection(SocketAddress remoteSocketAddress)

Specified by:

canAcceptNewConnection in interface AmqpPort<AmqpPortImpl>

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface AmqpPort<AmqpPortImpl>

getProtocolHandshakeTimeout

public long getProtocolHandshakeTimeout()

Specified by:

getProtocolHandshakeTimeout in interface AmqpPort<AmqpPortImpl>