org.apache.qpid.server.model.port

Interface AmqpPort<X extends AmqpPort<X>>

All Superinterfaces:

ClientAuthCapablePort<X>, ConfiguredObject<X>, Port<X>, PortWithAuthProvider<X>

All Known Implementing Classes:

AmqpPortImpl

public interface AmqpPort<X extends AmqpPort<X>>
extends ClientAuthCapablePort<X>

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_AMQP_NEED_CLIENT_AUTH
static String	DEFAULT_AMQP_PROTOCOLS
static String	DEFAULT_AMQP_TCP_NO_DELAY
static String	DEFAULT_AMQP_WANT_CLIENT_AUTH
static int	DEFAULT_MAX_MESSAGE_SIZE
static int	DEFAULT_MAX_OPEN_CONNECTIONS
static int	DEFAULT_OPEN_CONNECTIONS_WARN_PERCENT
static int	DEFAULT_PORT_AMQP_ACCEPT_BACKLOG
static long	DEFAULT_PORT_AMQP_NUMBER_OF_SELECTORS
static long	DEFAULT_PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE
static long	DEFAULT_PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT
static long	DEFAULT_PORT_AMQP_THREAD_POOL_SIZE
static long	DEFAULT_PROTOCOL_HANDSHAKE_TIMEOUT
static String	INSTALLED_PROTOCOLS
static String	MAX_OPEN_CONNECTIONS
static String	NUMBER_OF_SELECTORS
static String	OPEN_CONNECTIONS_WARN_PERCENT
static String	PORT_AMQP_ACCEPT_BACKLOG
static String	PORT_AMQP_NUMBER_OF_SELECTORS
static String	PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE
static String	PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT
static String	PORT_AMQP_THREAD_POOL_SIZE
static String	PORT_MAX_MESSAGE_SIZE
static String	PORT_MAX_OPEN_CONNECTIONS
static String	PROTOCOL_HANDSHAKE_TIMEOUT
static String	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

Method Summary

Modifier and Type	Method and Description
boolean	canAcceptNewConnection(SocketAddress remoteSocketAddress)
VirtualHostAlias	createVirtualHostAlias(Map<String,Object> attributes)
int	decrementConnectionCount()
AuthenticationProvider	getAuthenticationProvider()
String	getBindingAddress()
TrustStore<?>	getClientCertRecorder()
int	getConnectionCount()
int	getMaxOpenConnections()
boolean	getNeedClientAuth()
int	getNetworkBufferSize()
int	getNumberOfSelectors()
long	getProtocolHandshakeTimeout()
Set<Protocol>	getProtocols()
SSLContext	getSSLContext()
int	getThreadPoolSize()
Set<Transport>	getTransports()
VirtualHostImpl	getVirtualHost(String name)
boolean	getWantClientAuth()
int	incrementConnectionCount()
boolean	isTcpNoDelay()

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_AMQP_TCP_NO_DELAY

static final String DEFAULT_AMQP_TCP_NO_DELAY

See Also:

Constant Field Values

DEFAULT_AMQP_NEED_CLIENT_AUTH

static final String DEFAULT_AMQP_NEED_CLIENT_AUTH

See Also:

Constant Field Values

DEFAULT_AMQP_WANT_CLIENT_AUTH

static final String DEFAULT_AMQP_WANT_CLIENT_AUTH

See Also:

Constant Field Values

MAX_OPEN_CONNECTIONS

static final String MAX_OPEN_CONNECTIONS

See Also:

Constant Field Values

THREAD_POOL_SIZE

static final String THREAD_POOL_SIZE

See Also:

Constant Field Values

NUMBER_OF_SELECTORS

static final String NUMBER_OF_SELECTORS

See Also:

Constant Field Values

DEFAULT_AMQP_PROTOCOLS

static final String DEFAULT_AMQP_PROTOCOLS

See Also:

Constant Field Values

PORT_AMQP_THREAD_POOL_SIZE

static final String PORT_AMQP_THREAD_POOL_SIZE

See Also:

Constant Field Values

PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT

static final String PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT

See Also:

Constant Field Values

PORT_AMQP_NUMBER_OF_SELECTORS

static final String PORT_AMQP_NUMBER_OF_SELECTORS

See Also:

Constant Field Values

PORT_AMQP_ACCEPT_BACKLOG

static final String PORT_AMQP_ACCEPT_BACKLOG

See Also:

Constant Field Values

PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE

static final String PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE

See Also:

Constant Field Values

INSTALLED_PROTOCOLS

static final String INSTALLED_PROTOCOLS

PORT_MAX_OPEN_CONNECTIONS

static final String PORT_MAX_OPEN_CONNECTIONS

See Also:

Constant Field Values

DEFAULT_MAX_OPEN_CONNECTIONS

static final int DEFAULT_MAX_OPEN_CONNECTIONS

See Also:

Constant Field Values

DEFAULT_PORT_AMQP_THREAD_POOL_SIZE

static final long DEFAULT_PORT_AMQP_THREAD_POOL_SIZE

See Also:

Constant Field Values

DEFAULT_PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT

static final long DEFAULT_PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT

See Also:

Constant Field Values

DEFAULT_PORT_AMQP_NUMBER_OF_SELECTORS

static final long DEFAULT_PORT_AMQP_NUMBER_OF_SELECTORS

DEFAULT_PORT_AMQP_ACCEPT_BACKLOG

static final int DEFAULT_PORT_AMQP_ACCEPT_BACKLOG

See Also:

Constant Field Values

PORT_MAX_MESSAGE_SIZE

static final String PORT_MAX_MESSAGE_SIZE

See Also:

Constant Field Values

DEFAULT_MAX_MESSAGE_SIZE

static final int DEFAULT_MAX_MESSAGE_SIZE

See Also:

Constant Field Values

OPEN_CONNECTIONS_WARN_PERCENT

static final String OPEN_CONNECTIONS_WARN_PERCENT

See Also:

Constant Field Values

DEFAULT_OPEN_CONNECTIONS_WARN_PERCENT

static final int DEFAULT_OPEN_CONNECTIONS_WARN_PERCENT

See Also:

Constant Field Values

DEFAULT_PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE

static final long DEFAULT_PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE

See Also:

Constant Field Values

PROTOCOL_HANDSHAKE_TIMEOUT

static final String PROTOCOL_HANDSHAKE_TIMEOUT

See Also:

Constant Field Values

DEFAULT_PROTOCOL_HANDSHAKE_TIMEOUT

static final long DEFAULT_PROTOCOL_HANDSHAKE_TIMEOUT

See Also:

Constant Field Values

Method Detail

getSSLContext

SSLContext getSSLContext()

getBindingAddress

String getBindingAddress()

isTcpNoDelay

boolean isTcpNoDelay()

getThreadPoolSize

int getThreadPoolSize()

getNumberOfSelectors

int getNumberOfSelectors()

getNeedClientAuth

boolean getNeedClientAuth()

Specified by:

getNeedClientAuth in interface ClientAuthCapablePort<X extends AmqpPort<X>>

getWantClientAuth

boolean getWantClientAuth()

Specified by:

getWantClientAuth in interface ClientAuthCapablePort<X extends AmqpPort<X>>

getClientCertRecorder

TrustStore<?> getClientCertRecorder()

Specified by:

getClientCertRecorder in interface ClientAuthCapablePort<X extends AmqpPort<X>>

getAuthenticationProvider

AuthenticationProvider getAuthenticationProvider()

Specified by:

getAuthenticationProvider in interface PortWithAuthProvider<X extends AmqpPort<X>>

getTransports

Set<Transport> getTransports()

Specified by:

getTransports in interface Port<X extends AmqpPort<X>>

getProtocols

Set<Protocol> getProtocols()

Specified by:

getProtocols in interface Port<X extends AmqpPort<X>>

getMaxOpenConnections

int getMaxOpenConnections()

getConnectionCount

int getConnectionCount()

getProtocolHandshakeTimeout

long getProtocolHandshakeTimeout()

getVirtualHost

VirtualHostImpl getVirtualHost(String name)

canAcceptNewConnection

boolean canAcceptNewConnection(SocketAddress remoteSocketAddress)

incrementConnectionCount

int incrementConnectionCount()

decrementConnectionCount

int decrementConnectionCount()

createVirtualHostAlias

VirtualHostAlias createVirtualHostAlias(Map<String,Object> attributes)

getNetworkBufferSize

int getNetworkBufferSize()