public class AmqpClientOptions
extends io.vertx.proton.ProtonClientOptions
ProtonClientOptions for details.DEFAULT_HOSTNAME_VERIFICATION_ALGORITHM, DEFAULT_RECONNECT_ATTEMPTS, DEFAULT_RECONNECT_INTERVAL, DEFAULT_REGISTER_WRITE_HANDLERDEFAULT_CONNECT_TIMEOUT, DEFAULT_METRICS_NAME, DEFAULT_TRUST_ALLDEFAULT_ENABLED_SECURE_TRANSPORT_PROTOCOLS, DEFAULT_IDLE_TIMEOUT, DEFAULT_IDLE_TIMEOUT_TIME_UNIT, DEFAULT_READ_IDLE_TIMEOUT, 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_TCP_USER_TIMEOUT, DEFAULT_USE_ALPN, DEFAULT_WRITE_IDLE_TIMEOUTDEFAULT_LOG_ACTIVITY_FORMAT, 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, setUseAlpnaddNonProxyHost, getApplicationLayerProtocols, getHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, isRegisterWriteHandler, removeEnabledCipherSuite, setActivityLogDataFormat, setApplicationLayerProtocols, setNonProxyHosts, setReadIdleTimeout, setRegisterWriteHandler, setWriteIdleTimeoutgetConnectTimeout, getLocalAddress, getMetricsName, getNonProxyHosts, getProxyOptions, isTrustAll, setTcpUserTimeoutgetCrlPaths, getCrlValues, getEnabledCipherSuites, getEnabledSecureTransportProtocols, getIdleTimeout, getIdleTimeoutUnit, getJdkSslEngineOptions, getKeyCertOptions, getKeyStoreOptions, getOpenSslEngineOptions, getPemKeyCertOptions, getPemTrustOptions, getPfxKeyCertOptions, getPfxTrustOptions, getReadIdleTimeout, getSoLinger, getSslEngineOptions, getSslHandshakeTimeout, getSslHandshakeTimeoutUnit, getSslOptions, getTcpUserTimeout, getTrustOptions, getTrustStoreOptions, getWriteIdleTimeout, isSsl, isTcpCork, isTcpFastOpen, isTcpKeepAlive, isTcpNoDelay, isTcpQuickAck, isUseAlpngetActivityLogDataFormat, getLogActivity, getReceiveBufferSize, getSendBufferSize, getTrafficClass, isReuseAddress, isReusePortpublic AmqpClientOptions()
public AmqpClientOptions(JsonObject json)
public AmqpClientOptions(AmqpClientOptions other)
public JsonObject toJson()
ClientOptionsBasetoJson in class io.vertx.proton.ProtonClientOptionspublic 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 variableAmqpClientOptionspublic 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.AmqpClientOptionspublic String getUsername()
public AmqpClientOptions setUsername(String username)
username - the username, defaults to system variable amqp-client-username and
to AMQP_CLIENT_USERNAME environment variable.AmqpClientOptionspublic String getPassword()
public AmqpClientOptions setPassword(String pwd)
pwd - the password, defaults to system variable amqp-client-password and to
AMQP_CLIENT_PASSWORD environment variable.AmqpClientOptionspublic String getContainerId()
public AmqpClientOptions setContainerId(String containerId)
containerId - the container idAmqpClientOptionspublic 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.ProtonClientOptionsProtonClientOptions.addEnabledSaslMechanism(String)public AmqpClientOptions setSendBufferSize(int sendBufferSize)
NetworkOptionssetSendBufferSize in class io.vertx.proton.ProtonClientOptionssendBufferSize - the buffers size, in bytesProtonClientOptions.setSendBufferSize(int)public AmqpClientOptions setReceiveBufferSize(int receiveBufferSize)
NetworkOptionssetReceiveBufferSize in class io.vertx.proton.ProtonClientOptionsreceiveBufferSize - the buffers size, in bytesProtonClientOptions.setReceiveBufferSize(int)public AmqpClientOptions setReuseAddress(boolean reuseAddress)
NetworkOptionssetReuseAddress in class io.vertx.proton.ProtonClientOptionsreuseAddress - the value of reuse addressProtonClientOptions.setReuseAddress(boolean)public AmqpClientOptions setTrafficClass(int trafficClass)
NetworkOptionssetTrafficClass in class io.vertx.proton.ProtonClientOptionstrafficClass - the value of traffic classProtonClientOptions.setTrafficClass(int)public AmqpClientOptions setTcpNoDelay(boolean tcpNoDelay)
TCPSSLOptionssetTcpNoDelay in class io.vertx.proton.ProtonClientOptionstcpNoDelay - true if TCP no delay is enabled (Nagle disabled)ProtonClientOptions.setTcpNoDelay(boolean)public AmqpClientOptions setTcpKeepAlive(boolean tcpKeepAlive)
TCPSSLOptionssetTcpKeepAlive in class io.vertx.proton.ProtonClientOptionstcpKeepAlive - true if TCP keep alive is enabledProtonClientOptions.setTcpKeepAlive(boolean)public AmqpClientOptions setSoLinger(int soLinger)
TCPSSLOptionssetSoLinger in class io.vertx.proton.ProtonClientOptionssoLinger - true if SO_linger is enabledProtonClientOptions.setSoLinger(int)public AmqpClientOptions setIdleTimeout(int idleTimeout)
TCPSSLOptionsTCPSSLOptions.setIdleTimeoutUnit(TimeUnit)setIdleTimeout in class io.vertx.proton.ProtonClientOptionsidleTimeout - the timeoutProtonClientOptions.setIdleTimeout(int)public AmqpClientOptions setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
TCPSSLOptionssetIdleTimeoutUnit in class io.vertx.proton.ProtonClientOptionsidleTimeoutUnit - specify time unit.ProtonClientOptions.setIdleTimeoutUnit(TimeUnit)public AmqpClientOptions setSsl(boolean ssl)
TCPSSLOptionssetSsl in class io.vertx.proton.ProtonClientOptionsssl - true if enabledProtonClientOptions.setSsl(boolean)public AmqpClientOptions setSslHandshakeTimeout(long sslHandshakeTimeout)
TCPSSLOptionssetSslHandshakeTimeout in class io.vertx.proton.ProtonClientOptionssslHandshakeTimeout - the SSL handshake timeout to set, in millisecondsProtonClientOptions#setSslHandshakeTimeout(boolean)public AmqpClientOptions setSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit)
TCPSSLOptionssetSslHandshakeTimeoutUnit in class io.vertx.proton.ProtonClientOptionssslHandshakeTimeoutUnit - specify time unit.ProtonClientOptions.setSslHandshakeTimeoutUnit(TimeUnit)public AmqpClientOptions setKeyStoreOptions(JksOptions options)
TCPSSLOptionssetKeyStoreOptions in class io.vertx.proton.ProtonClientOptionsoptions - the key store in jks formatProtonClientOptions.setKeyStoreOptions(JksOptions)public AmqpClientOptions setKeyCertOptions(KeyCertOptions options)
TCPSSLOptionssetKeyCertOptions in class io.vertx.proton.ProtonClientOptionsoptions - the key store optionsProtonClientOptions#setKeyCertOptions(PfxOptions)public AmqpClientOptions setPfxKeyCertOptions(PfxOptions options)
TCPSSLOptionssetPfxKeyCertOptions in class io.vertx.proton.ProtonClientOptionsoptions - the key cert options in pfx formatProtonClientOptions.setPfxKeyCertOptions(PfxOptions)public AmqpClientOptions setPemKeyCertOptions(PemKeyCertOptions options)
TCPSSLOptionssetPemKeyCertOptions in class io.vertx.proton.ProtonClientOptionsoptions - the options in pem formatProtonClientOptions.setPemKeyCertOptions(PemKeyCertOptions)public AmqpClientOptions setTrustOptions(TrustOptions options)
TCPSSLOptionssetTrustOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust optionsProtonClientOptions#setTrustStoreOptions(TrustOptions)public AmqpClientOptions setTrustStoreOptions(JksOptions options)
TCPSSLOptionssetTrustStoreOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust options in jks formatProtonClientOptions.setTrustStoreOptions(JksOptions)public AmqpClientOptions setPemTrustOptions(PemTrustOptions options)
TCPSSLOptionssetPemTrustOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust options in pem formatProtonClientOptions.setPemTrustOptions(PemTrustOptions)public AmqpClientOptions setPfxTrustOptions(PfxOptions options)
TCPSSLOptionssetPfxTrustOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust options in pfx formatProtonClientOptions.setPfxTrustOptions(PfxOptions)public AmqpClientOptions addEnabledCipherSuite(String suite)
TCPSSLOptionsaddEnabledCipherSuite in class io.vertx.proton.ProtonClientOptionssuite - the suiteProtonClientOptions.addEnabledCipherSuite(String)public AmqpClientOptions addCrlPath(String crlPath)
TCPSSLOptionsaddCrlPath in class io.vertx.proton.ProtonClientOptionscrlPath - the pathProtonClientOptions.addCrlPath(String)public AmqpClientOptions addCrlValue(Buffer crlValue)
TCPSSLOptionsaddCrlValue in class io.vertx.proton.ProtonClientOptionscrlValue - the valueProtonClientOptions.addCrlValue(Buffer)public AmqpClientOptions setTrustAll(boolean trustAll)
ClientOptionsBasesetTrustAll in class io.vertx.proton.ProtonClientOptionstrustAll - true if all should be trustedProtonClientOptions.setTrustAll(boolean)public AmqpClientOptions setConnectTimeout(int connectTimeout)
ClientOptionsBasesetConnectTimeout in class io.vertx.proton.ProtonClientOptionsconnectTimeout - connect timeout, in msProtonClientOptions.setConnectTimeout(int)public AmqpClientOptions setReconnectAttempts(int attempts)
NetClientOptionssetReconnectAttempts in class io.vertx.proton.ProtonClientOptionsattempts - the maximum number of reconnect attemptsProtonClientOptions.setReconnectAttempts(int)public AmqpClientOptions setReconnectInterval(long interval)
NetClientOptionssetReconnectInterval in class io.vertx.proton.ProtonClientOptionsinterval - the reconnect interval in msProtonClientOptions.setReconnectInterval(long)public AmqpClientOptions addEnabledSecureTransportProtocol(String protocol)
TCPSSLOptionsaddEnabledSecureTransportProtocol in class io.vertx.proton.ProtonClientOptionsprotocol - the SSL/TLS protocol to enableProtonClientOptions.addEnabledSecureTransportProtocol(String)public AmqpClientOptions setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
NetClientOptionssetHostnameVerificationAlgorithm in class io.vertx.proton.ProtonClientOptionshostnameVerificationAlgorithm - should be HTTPS, LDAPS or an empty StringProtonClientOptions.setHostnameVerificationAlgorithm(String)public AmqpClientOptions setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions)
setJdkSslEngineOptions in class io.vertx.proton.ProtonClientOptionsProtonClientOptions.setJdkSslEngineOptions(JdkSSLEngineOptions)public AmqpClientOptions setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions)
setOpenSslEngineOptions in class io.vertx.proton.ProtonClientOptionsProtonClientOptions.setOpenSslEngineOptions(OpenSSLEngineOptions)public AmqpClientOptions setSslEngineOptions(SSLEngineOptions sslEngineOptions)
TCPSSLOptionssetSslEngineOptions in class io.vertx.proton.ProtonClientOptionssslEngineOptions - the ssl engine to useProtonClientOptions.setSslEngineOptions(SSLEngineOptions)public AmqpClientOptions setLocalAddress(String localAddress)
ClientOptionsBasesetLocalAddress in class io.vertx.proton.ProtonClientOptionslocalAddress - the local addressProtonClientOptions.setLocalAddress(String)public AmqpClientOptions setReusePort(boolean reusePort)
NetworkOptionssetReusePort in class io.vertx.proton.ProtonClientOptionsreusePort - the value of reuse portProtonClientOptions.setReusePort(boolean)public AmqpClientOptions setTcpCork(boolean tcpCork)
TCPSSLOptionsTCP_CORK option - only with linux native transport.setTcpCork in class io.vertx.proton.ProtonClientOptionstcpCork - the cork valueProtonClientOptions.setTcpCork(boolean)public AmqpClientOptions setTcpFastOpen(boolean tcpFastOpen)
TCPSSLOptionsTCP_FASTOPEN option - only with linux native transport.setTcpFastOpen in class io.vertx.proton.ProtonClientOptionstcpFastOpen - the fast open valueProtonClientOptions.setTcpFastOpen(boolean)public AmqpClientOptions setTcpQuickAck(boolean tcpQuickAck)
TCPSSLOptionsTCP_QUICKACK option - only with linux native transport.setTcpQuickAck in class io.vertx.proton.ProtonClientOptionstcpQuickAck - the quick ack valueProtonClientOptions.setTcpQuickAck(boolean)public AmqpClientOptions removeEnabledSecureTransportProtocol(String protocol)
TCPSSLOptionsremoveEnabledSecureTransportProtocol in class io.vertx.proton.ProtonClientOptionsprotocol - the SSL/TLS protocol to disableProtonClientOptions.removeEnabledSecureTransportProtocol(String)public AmqpClientOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
TCPSSLOptionssetEnabledSecureTransportProtocols in class io.vertx.proton.ProtonClientOptionsenabledSecureTransportProtocols - the SSL/TLS protocols to enableProtonClientOptions.setEnabledSecureTransportProtocols(Set)public AmqpClientOptions setVirtualHost(String virtualHost)
setVirtualHost in class io.vertx.proton.ProtonClientOptionsProtonClientOptions.setVirtualHost(String)public AmqpClientOptions setSniServerName(String sniServerName)
setSniServerName in class io.vertx.proton.ProtonClientOptionsProtonClientOptions.setSniServerName(String)public AmqpClientOptions setHeartbeat(int heartbeat)
setHeartbeat in class io.vertx.proton.ProtonClientOptionsProtonClientOptions.setHeartbeat(int)public AmqpClientOptions setMaxFrameSize(int maxFrameSize)
setMaxFrameSize in class io.vertx.proton.ProtonClientOptionsProtonClientOptions.setMaxFrameSize(int)Copyright © 2023 Eclipse. All rights reserved.