public class AmqpClientOptions
extends io.vertx.proton.ProtonClientOptions
ProtonClientOptions
for details.DEFAULT_HOSTNAME_VERIFICATION_ALGORITHM, DEFAULT_RECONNECT_ATTEMPTS, DEFAULT_RECONNECT_INTERVAL
DEFAULT_CONNECT_TIMEOUT, DEFAULT_METRICS_NAME, DEFAULT_TRUST_ALL
DEFAULT_ENABLED_SECURE_TRANSPORT_PROTOCOLS, DEFAULT_IDLE_TIMEOUT, DEFAULT_IDLE_TIMEOUT_TIME_UNIT, DEFAULT_SO_LINGER, DEFAULT_SSL, DEFAULT_SSL_ENGINE, DEFAULT_SSL_HANDSHAKE_TIMEOUT, DEFAULT_SSL_HANDSHAKE_TIMEOUT_TIME_UNIT, DEFAULT_TCP_CORK, DEFAULT_TCP_FAST_OPEN, DEFAULT_TCP_KEEP_ALIVE, DEFAULT_TCP_NO_DELAY, DEFAULT_TCP_QUICKACK, DEFAULT_USE_ALPN
DEFAULT_LOG_ENABLED, DEFAULT_RECEIVE_BUFFER_SIZE, DEFAULT_REUSE_ADDRESS, DEFAULT_REUSE_PORT, DEFAULT_SEND_BUFFER_SIZE, DEFAULT_TRAFFIC_CLASS
Constructor and Description |
---|
AmqpClientOptions() |
AmqpClientOptions(AmqpClientOptions other) |
AmqpClientOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
AmqpClientOptions |
addCrlPath(String crlPath)
Add a CRL path
|
AmqpClientOptions |
addCrlValue(Buffer crlValue)
Add a CRL value
|
AmqpClientOptions |
addEnabledCipherSuite(String suite)
Add an enabled cipher suite, appended to the ordered suites.
|
AmqpClientOptions |
addEnabledSaslMechanism(String saslMechanism) |
AmqpClientOptions |
addEnabledSecureTransportProtocol(String protocol)
Add an enabled SSL/TLS protocols, appended to the ordered protocols.
|
String |
getConnectionHostname()
Get the connection hostname override for the AMQP Open frame hostname
|
String |
getContainerId() |
String |
getHost() |
String |
getPassword() |
int |
getPort() |
String |
getUsername() |
AmqpClientOptions |
removeEnabledSecureTransportProtocol(String protocol)
Removes an enabled SSL/TLS protocol from the ordered protocols.
|
AmqpClientOptions |
setConnectionHostname(String hostname)
Explicitly override the hostname value used for the AMQP Open frame.
|
AmqpClientOptions |
setConnectTimeout(int connectTimeout)
Set the connect timeout
|
AmqpClientOptions |
setContainerId(String containerId)
Sets the container id.
|
AmqpClientOptions |
setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
Sets the list of enabled SSL/TLS protocols.
|
AmqpClientOptions |
setHeartbeat(int heartbeat) |
AmqpClientOptions |
setHost(String host)
Sets the host.
|
AmqpClientOptions |
setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
Set the hostname verification algorithm interval
To disable hostname verification, set hostnameVerificationAlgorithm to an empty String
|
AmqpClientOptions |
setIdleTimeout(int idleTimeout)
Set the idle timeout, default time unit is seconds.
|
AmqpClientOptions |
setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
Set the idle timeout unit.
|
AmqpClientOptions |
setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions) |
AmqpClientOptions |
setKeyCertOptions(KeyCertOptions options)
Set the key/cert options.
|
AmqpClientOptions |
setKeyStoreOptions(JksOptions options)
Set the key/cert options in jks format, aka Java keystore.
|
AmqpClientOptions |
setLocalAddress(String localAddress)
Set the local interface to bind for network connections.
|
AmqpClientOptions |
setMaxFrameSize(int maxFrameSize) |
AmqpClientOptions |
setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions) |
AmqpClientOptions |
setPassword(String pwd)
Sets the password.
|
AmqpClientOptions |
setPemKeyCertOptions(PemKeyCertOptions options)
Set the key/cert store options in pem format.
|
AmqpClientOptions |
setPemTrustOptions(PemTrustOptions options)
Set the trust options in pem format
|
AmqpClientOptions |
setPfxKeyCertOptions(PfxOptions options)
Set the key/cert options in pfx format.
|
AmqpClientOptions |
setPfxTrustOptions(PfxOptions options)
Set the trust options in pfx format
|
AmqpClientOptions |
setPort(int port)
Sets the port.
|
AmqpClientOptions |
setReceiveBufferSize(int receiveBufferSize)
Set the TCP receive buffer size
|
AmqpClientOptions |
setReconnectAttempts(int attempts)
Set the value of reconnect attempts
|
AmqpClientOptions |
setReconnectInterval(long interval)
Set the reconnect interval
|
AmqpClientOptions |
setReuseAddress(boolean reuseAddress)
Set the value of reuse address
|
AmqpClientOptions |
setReusePort(boolean reusePort)
Set the value of reuse port.
|
AmqpClientOptions |
setSendBufferSize(int sendBufferSize)
Set the TCP send buffer size
|
AmqpClientOptions |
setSniServerName(String sniServerName) |
AmqpClientOptions |
setSoLinger(int soLinger)
Set whether SO_linger keep alive is enabled
|
AmqpClientOptions |
setSsl(boolean ssl)
Set whether SSL/TLS is enabled
|
AmqpClientOptions |
setSslEngineOptions(SSLEngineOptions sslEngineOptions)
Set to use SSL engine implementation to use.
|
AmqpClientOptions |
setSslHandshakeTimeout(long sslHandshakeTimeout)
Set the SSL handshake timeout, default time unit is seconds.
|
AmqpClientOptions |
setSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit)
Set the SSL handshake timeout unit.
|
AmqpClientOptions |
setTcpCork(boolean tcpCork)
Enable the
TCP_CORK option - only with linux native transport. |
AmqpClientOptions |
setTcpFastOpen(boolean tcpFastOpen)
Enable the
TCP_FASTOPEN option - only with linux native transport. |
AmqpClientOptions |
setTcpKeepAlive(boolean tcpKeepAlive)
Set whether TCP keep alive is enabled
|
AmqpClientOptions |
setTcpNoDelay(boolean tcpNoDelay)
Set whether TCP no delay is enabled
|
AmqpClientOptions |
setTcpQuickAck(boolean tcpQuickAck)
Enable the
TCP_QUICKACK option - only with linux native transport. |
AmqpClientOptions |
setTrafficClass(int trafficClass)
Set the value of traffic class
|
AmqpClientOptions |
setTrustAll(boolean trustAll)
Set whether all server certificates should be trusted
|
AmqpClientOptions |
setTrustOptions(TrustOptions options)
Set the trust options.
|
AmqpClientOptions |
setTrustStoreOptions(JksOptions options)
Set the trust options in jks format, aka Java truststore
|
AmqpClientOptions |
setUsername(String username)
Sets the username.
|
AmqpClientOptions |
setVirtualHost(String virtualHost) |
JsonObject |
toJson()
Convert to JSON
|
equals, getEnabledSaslMechanisms, getHeartbeat, getMaxFrameSize, getSniServerName, getVirtualHost, hashCode, setLogActivity, setMetricsName, setProxyOptions, setUseAlpn
getApplicationLayerProtocols, getHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, setApplicationLayerProtocols
getConnectTimeout, getLocalAddress, getMetricsName, getProxyOptions, isTrustAll
getCrlPaths, getCrlValues, getEnabledCipherSuites, getEnabledSecureTransportProtocols, getIdleTimeout, getIdleTimeoutUnit, getJdkSslEngineOptions, getKeyCertOptions, getKeyStoreOptions, getOpenSslEngineOptions, getPemKeyCertOptions, getPemTrustOptions, getPfxKeyCertOptions, getPfxTrustOptions, getSoLinger, getSslEngineOptions, getSslHandshakeTimeout, getSslHandshakeTimeoutUnit, getTrustOptions, getTrustStoreOptions, isSsl, isTcpCork, isTcpFastOpen, isTcpKeepAlive, isTcpNoDelay, isTcpQuickAck, isUseAlpn
getLogActivity, getReceiveBufferSize, getSendBufferSize, getTrafficClass, isReuseAddress, isReusePort
public AmqpClientOptions()
public AmqpClientOptions(JsonObject json)
public AmqpClientOptions(AmqpClientOptions other)
public JsonObject toJson()
ClientOptionsBase
toJson
in class io.vertx.proton.ProtonClientOptions
public String getHost()
public AmqpClientOptions setHost(String host)
host
- the host, must not be null
when the client attempt to connect. Defaults to system variable
amqp-client-host
and to AMQP_CLIENT_HOST
environment variableAmqpClientOptions
public int getPort()
public AmqpClientOptions setPort(int port)
port
- the port, defaults to system variable amqp-client-port
and to AMQP_CLIENT_PORT
environment variable and if neither is set 5672
.AmqpClientOptions
public String getUsername()
public AmqpClientOptions setUsername(String username)
username
- the username, defaults to system variable amqp-client-username
and
to AMQP_CLIENT_USERNAME
environment variable.AmqpClientOptions
public String getPassword()
public AmqpClientOptions setPassword(String pwd)
pwd
- the password, defaults to system variable amqp-client-password
and to
AMQP_CLIENT_PASSWORD
environment variable.AmqpClientOptions
public String getContainerId()
public AmqpClientOptions setContainerId(String containerId)
containerId
- the container idAmqpClientOptions
public String getConnectionHostname()
public AmqpClientOptions setConnectionHostname(String hostname)
setHost(String)
will be used in the Open frame by default.hostname
- the hostname override value to use as the Open frame hostnamepublic AmqpClientOptions addEnabledSaslMechanism(String saslMechanism)
addEnabledSaslMechanism
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.addEnabledSaslMechanism(String)
public AmqpClientOptions setSendBufferSize(int sendBufferSize)
NetworkOptions
setSendBufferSize
in class io.vertx.proton.ProtonClientOptions
sendBufferSize
- the buffers size, in bytesProtonClientOptions.setSendBufferSize(int)
public AmqpClientOptions setReceiveBufferSize(int receiveBufferSize)
NetworkOptions
setReceiveBufferSize
in class io.vertx.proton.ProtonClientOptions
receiveBufferSize
- the buffers size, in bytesProtonClientOptions.setReceiveBufferSize(int)
public AmqpClientOptions setReuseAddress(boolean reuseAddress)
NetworkOptions
setReuseAddress
in class io.vertx.proton.ProtonClientOptions
reuseAddress
- the value of reuse addressProtonClientOptions.setReuseAddress(boolean)
public AmqpClientOptions setTrafficClass(int trafficClass)
NetworkOptions
setTrafficClass
in class io.vertx.proton.ProtonClientOptions
trafficClass
- the value of traffic classProtonClientOptions.setTrafficClass(int)
public AmqpClientOptions setTcpNoDelay(boolean tcpNoDelay)
TCPSSLOptions
setTcpNoDelay
in class io.vertx.proton.ProtonClientOptions
tcpNoDelay
- true if TCP no delay is enabled (Nagle disabled)ProtonClientOptions.setTcpNoDelay(boolean)
public AmqpClientOptions setTcpKeepAlive(boolean tcpKeepAlive)
TCPSSLOptions
setTcpKeepAlive
in class io.vertx.proton.ProtonClientOptions
tcpKeepAlive
- true if TCP keep alive is enabledProtonClientOptions.setTcpKeepAlive(boolean)
public AmqpClientOptions setSoLinger(int soLinger)
TCPSSLOptions
setSoLinger
in class io.vertx.proton.ProtonClientOptions
soLinger
- true if SO_linger is enabledProtonClientOptions.setSoLinger(int)
public AmqpClientOptions setIdleTimeout(int idleTimeout)
TCPSSLOptions
TCPSSLOptions.setIdleTimeoutUnit(TimeUnit)
setIdleTimeout
in class io.vertx.proton.ProtonClientOptions
idleTimeout
- the timeout, in secondsProtonClientOptions.setIdleTimeout(int)
public AmqpClientOptions setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
TCPSSLOptions
setIdleTimeoutUnit
in class io.vertx.proton.ProtonClientOptions
idleTimeoutUnit
- specify time unit.ProtonClientOptions.setIdleTimeoutUnit(TimeUnit)
public AmqpClientOptions setSsl(boolean ssl)
TCPSSLOptions
setSsl
in class io.vertx.proton.ProtonClientOptions
ssl
- true if enabledProtonClientOptions.setSsl(boolean)
public AmqpClientOptions setSslHandshakeTimeout(long sslHandshakeTimeout)
TCPSSLOptions
setSslHandshakeTimeout
in class io.vertx.proton.ProtonClientOptions
sslHandshakeTimeout
- the SSL handshake timeout to set, in millisecondsProtonClientOptions#setSslHandshakeTimeout(boolean)
public AmqpClientOptions setSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit)
TCPSSLOptions
setSslHandshakeTimeoutUnit
in class io.vertx.proton.ProtonClientOptions
sslHandshakeTimeoutUnit
- specify time unit.ProtonClientOptions.setSslHandshakeTimeoutUnit(TimeUnit)
public AmqpClientOptions setKeyStoreOptions(JksOptions options)
TCPSSLOptions
setKeyStoreOptions
in class io.vertx.proton.ProtonClientOptions
options
- the key store in jks formatProtonClientOptions.setKeyStoreOptions(JksOptions)
public AmqpClientOptions setKeyCertOptions(KeyCertOptions options)
TCPSSLOptions
setKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
options
- the key store optionsProtonClientOptions#setKeyCertOptions(PfxOptions)
public AmqpClientOptions setPfxKeyCertOptions(PfxOptions options)
TCPSSLOptions
setPfxKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
options
- the key cert options in pfx formatProtonClientOptions.setPfxKeyCertOptions(PfxOptions)
public AmqpClientOptions setPemKeyCertOptions(PemKeyCertOptions options)
TCPSSLOptions
setPemKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
options
- the options in pem formatProtonClientOptions.setPemKeyCertOptions(PemKeyCertOptions)
public AmqpClientOptions setTrustOptions(TrustOptions options)
TCPSSLOptions
setTrustOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust optionsProtonClientOptions#setTrustStoreOptions(TrustOptions)
public AmqpClientOptions setTrustStoreOptions(JksOptions options)
TCPSSLOptions
setTrustStoreOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust options in jks formatProtonClientOptions.setTrustStoreOptions(JksOptions)
public AmqpClientOptions setPemTrustOptions(PemTrustOptions options)
TCPSSLOptions
setPemTrustOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust options in pem formatProtonClientOptions.setPemTrustOptions(PemTrustOptions)
public AmqpClientOptions setPfxTrustOptions(PfxOptions options)
TCPSSLOptions
setPfxTrustOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust options in pfx formatProtonClientOptions.setPfxTrustOptions(PfxOptions)
public AmqpClientOptions addEnabledCipherSuite(String suite)
TCPSSLOptions
addEnabledCipherSuite
in class io.vertx.proton.ProtonClientOptions
suite
- the suiteProtonClientOptions.addEnabledCipherSuite(String)
public AmqpClientOptions addCrlPath(String crlPath)
TCPSSLOptions
addCrlPath
in class io.vertx.proton.ProtonClientOptions
crlPath
- the pathProtonClientOptions.addCrlPath(String)
public AmqpClientOptions addCrlValue(Buffer crlValue)
TCPSSLOptions
addCrlValue
in class io.vertx.proton.ProtonClientOptions
crlValue
- the valueProtonClientOptions.addCrlValue(Buffer)
public AmqpClientOptions setTrustAll(boolean trustAll)
ClientOptionsBase
setTrustAll
in class io.vertx.proton.ProtonClientOptions
trustAll
- true if all should be trustedProtonClientOptions.setTrustAll(boolean)
public AmqpClientOptions setConnectTimeout(int connectTimeout)
ClientOptionsBase
setConnectTimeout
in class io.vertx.proton.ProtonClientOptions
connectTimeout
- connect timeout, in msProtonClientOptions.setConnectTimeout(int)
public AmqpClientOptions setReconnectAttempts(int attempts)
NetClientOptions
setReconnectAttempts
in class io.vertx.proton.ProtonClientOptions
attempts
- the maximum number of reconnect attemptsProtonClientOptions.setReconnectAttempts(int)
public AmqpClientOptions setReconnectInterval(long interval)
NetClientOptions
setReconnectInterval
in class io.vertx.proton.ProtonClientOptions
interval
- the reconnect interval in msProtonClientOptions.setReconnectInterval(long)
public AmqpClientOptions addEnabledSecureTransportProtocol(String protocol)
TCPSSLOptions
addEnabledSecureTransportProtocol
in class io.vertx.proton.ProtonClientOptions
protocol
- the SSL/TLS protocol to enableProtonClientOptions.addEnabledSecureTransportProtocol(String)
public AmqpClientOptions setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
NetClientOptions
setHostnameVerificationAlgorithm
in class io.vertx.proton.ProtonClientOptions
hostnameVerificationAlgorithm
- should be HTTPS, LDAPS or an empty StringProtonClientOptions.setHostnameVerificationAlgorithm(String)
public AmqpClientOptions setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions)
setJdkSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setJdkSslEngineOptions(JdkSSLEngineOptions)
public AmqpClientOptions setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions)
setOpenSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setOpenSslEngineOptions(OpenSSLEngineOptions)
public AmqpClientOptions setSslEngineOptions(SSLEngineOptions sslEngineOptions)
TCPSSLOptions
setSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
sslEngineOptions
- the ssl engine to useProtonClientOptions.setSslEngineOptions(SSLEngineOptions)
public AmqpClientOptions setLocalAddress(String localAddress)
ClientOptionsBase
setLocalAddress
in class io.vertx.proton.ProtonClientOptions
localAddress
- the local addressProtonClientOptions.setLocalAddress(String)
public AmqpClientOptions setReusePort(boolean reusePort)
NetworkOptions
setReusePort
in class io.vertx.proton.ProtonClientOptions
reusePort
- the value of reuse portProtonClientOptions.setReusePort(boolean)
public AmqpClientOptions setTcpCork(boolean tcpCork)
TCPSSLOptions
TCP_CORK
option - only with linux native transport.setTcpCork
in class io.vertx.proton.ProtonClientOptions
tcpCork
- the cork valueProtonClientOptions.setTcpCork(boolean)
public AmqpClientOptions setTcpFastOpen(boolean tcpFastOpen)
TCPSSLOptions
TCP_FASTOPEN
option - only with linux native transport.setTcpFastOpen
in class io.vertx.proton.ProtonClientOptions
tcpFastOpen
- the fast open valueProtonClientOptions.setTcpFastOpen(boolean)
public AmqpClientOptions setTcpQuickAck(boolean tcpQuickAck)
TCPSSLOptions
TCP_QUICKACK
option - only with linux native transport.setTcpQuickAck
in class io.vertx.proton.ProtonClientOptions
tcpQuickAck
- the quick ack valueProtonClientOptions.setTcpQuickAck(boolean)
public AmqpClientOptions removeEnabledSecureTransportProtocol(String protocol)
TCPSSLOptions
removeEnabledSecureTransportProtocol
in class io.vertx.proton.ProtonClientOptions
protocol
- the SSL/TLS protocol to disableProtonClientOptions.removeEnabledSecureTransportProtocol(String)
public AmqpClientOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
TCPSSLOptions
setEnabledSecureTransportProtocols
in class io.vertx.proton.ProtonClientOptions
enabledSecureTransportProtocols
- the SSL/TLS protocols to enableProtonClientOptions.setEnabledSecureTransportProtocols(Set)
public AmqpClientOptions setVirtualHost(String virtualHost)
setVirtualHost
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setVirtualHost(String)
public AmqpClientOptions setSniServerName(String sniServerName)
setSniServerName
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setSniServerName(String)
public AmqpClientOptions setHeartbeat(int heartbeat)
setHeartbeat
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setHeartbeat(int)
public AmqpClientOptions setMaxFrameSize(int maxFrameSize)
setMaxFrameSize
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setMaxFrameSize(int)
Copyright © 2021 Eclipse. All rights reserved.