public interface AmqpPort<X extends AmqpPort<X>> extends ClientAuthCapablePort<X>
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
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() |
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
static final String DEFAULT_AMQP_TCP_NO_DELAY
static final String DEFAULT_AMQP_NEED_CLIENT_AUTH
static final String DEFAULT_AMQP_WANT_CLIENT_AUTH
static final String MAX_OPEN_CONNECTIONS
static final String THREAD_POOL_SIZE
static final String NUMBER_OF_SELECTORS
static final String DEFAULT_AMQP_PROTOCOLS
static final String PORT_AMQP_THREAD_POOL_SIZE
static final String PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT
static final String PORT_AMQP_NUMBER_OF_SELECTORS
static final String PORT_AMQP_ACCEPT_BACKLOG
static final String PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE
static final String INSTALLED_PROTOCOLS
static final String PORT_MAX_OPEN_CONNECTIONS
static final int DEFAULT_MAX_OPEN_CONNECTIONS
static final long DEFAULT_PORT_AMQP_THREAD_POOL_SIZE
static final long DEFAULT_PORT_AMQP_THREAD_POOL_KEEP_ALIVE_TIMEOUT
static final long DEFAULT_PORT_AMQP_NUMBER_OF_SELECTORS
static final int DEFAULT_PORT_AMQP_ACCEPT_BACKLOG
static final String PORT_MAX_MESSAGE_SIZE
static final int DEFAULT_MAX_MESSAGE_SIZE
static final String OPEN_CONNECTIONS_WARN_PERCENT
static final int DEFAULT_OPEN_CONNECTIONS_WARN_PERCENT
static final long DEFAULT_PORT_AMQP_OUTBOUND_MESSAGE_BUFFER_SIZE
static final String PROTOCOL_HANDSHAKE_TIMEOUT
static final long DEFAULT_PROTOCOL_HANDSHAKE_TIMEOUT
SSLContext getSSLContext()
String getBindingAddress()
boolean isTcpNoDelay()
int getThreadPoolSize()
int getNumberOfSelectors()
boolean getNeedClientAuth()
getNeedClientAuth
in interface ClientAuthCapablePort<X extends AmqpPort<X>>
boolean getWantClientAuth()
getWantClientAuth
in interface ClientAuthCapablePort<X extends AmqpPort<X>>
TrustStore<?> getClientCertRecorder()
getClientCertRecorder
in interface ClientAuthCapablePort<X extends AmqpPort<X>>
AuthenticationProvider getAuthenticationProvider()
getAuthenticationProvider
in interface PortWithAuthProvider<X extends AmqpPort<X>>
Set<Transport> getTransports()
getTransports
in interface Port<X extends AmqpPort<X>>
Set<Protocol> getProtocols()
getProtocols
in interface Port<X extends AmqpPort<X>>
int getMaxOpenConnections()
int getConnectionCount()
long getProtocolHandshakeTimeout()
VirtualHostImpl getVirtualHost(String name)
boolean canAcceptNewConnection(SocketAddress remoteSocketAddress)
int incrementConnectionCount()
int decrementConnectionCount()
VirtualHostAlias createVirtualHostAlias(Map<String,Object> attributes)
int getNetworkBufferSize()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.