Package io.vertx.amqp
Class AmqpClientOptions
- java.lang.Object
-
- io.vertx.core.net.NetworkOptions
-
- io.vertx.core.net.TCPSSLOptions
-
- io.vertx.core.net.ClientOptionsBase
-
- io.vertx.core.net.NetClientOptions
-
- io.vertx.proton.ProtonClientOptions
-
- io.vertx.amqp.AmqpClientOptions
-
public class AmqpClientOptions extends io.vertx.proton.ProtonClientOptionsConfigures the AMQP Client. You can also configure the underlying Proton instance. Refer toProtonClientOptionsfor details.
-
-
Field Summary
-
Fields inherited from class io.vertx.core.net.NetClientOptions
DEFAULT_HOSTNAME_VERIFICATION_ALGORITHM, DEFAULT_RECONNECT_ATTEMPTS, DEFAULT_RECONNECT_INTERVAL, DEFAULT_REGISTER_WRITE_HANDLER
-
Fields inherited from class io.vertx.core.net.ClientOptionsBase
DEFAULT_CONNECT_TIMEOUT, DEFAULT_METRICS_NAME
-
Fields inherited from class io.vertx.core.net.TCPSSLOptions
DEFAULT_IDLE_TIMEOUT, DEFAULT_IDLE_TIMEOUT_TIME_UNIT, DEFAULT_READ_IDLE_TIMEOUT, DEFAULT_SO_LINGER, DEFAULT_SSL, DEFAULT_SSL_ENGINE, DEFAULT_TCP_CORK, DEFAULT_TCP_FAST_OPEN, DEFAULT_TCP_KEEP_ALIVE, DEFAULT_TCP_NO_DELAY, DEFAULT_TCP_QUICKACK, DEFAULT_TCP_USER_TIMEOUT, DEFAULT_WRITE_IDLE_TIMEOUT
-
Fields inherited from class io.vertx.core.net.NetworkOptions
DEFAULT_LOG_ACTIVITY_FORMAT, DEFAULT_LOG_ENABLED, DEFAULT_RECEIVE_BUFFER_SIZE, DEFAULT_REUSE_ADDRESS, DEFAULT_REUSE_PORT, DEFAULT_SEND_BUFFER_SIZE, DEFAULT_TRAFFIC_CLASS
-
-
Constructor Summary
Constructors Constructor Description AmqpClientOptions()AmqpClientOptions(AmqpClientOptions other)AmqpClientOptions(JsonObject json)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AmqpClientOptionsaddCrlPath(String crlPath)Add a CRL pathAmqpClientOptionsaddCrlValue(Buffer crlValue)Add a CRL valueAmqpClientOptionsaddEnabledCipherSuite(String suite)Add an enabled cipher suite, appended to the ordered suites.AmqpClientOptionsaddEnabledSaslMechanism(String saslMechanism)AmqpClientOptionsaddEnabledSecureTransportProtocol(String protocol)Add an enabled SSL/TLS protocols, appended to the ordered protocols.StringgetConnectionHostname()Get the connection hostname override for the AMQP Open frame hostnameStringgetContainerId()StringgetHost()StringgetPassword()intgetPort()StringgetUsername()AmqpClientOptionsremoveEnabledSecureTransportProtocol(String protocol)Removes an enabled SSL/TLS protocol from the ordered protocols.AmqpClientOptionssetConnectionHostname(String hostname)Explicitly override the hostname value used for the AMQP Open frame.AmqpClientOptionssetConnectTimeout(int connectTimeout)Set the connect timeoutAmqpClientOptionssetContainerId(String containerId)Sets the container id.AmqpClientOptionssetEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)Sets the list of enabled SSL/TLS protocols.AmqpClientOptionssetHeartbeat(int heartbeat)AmqpClientOptionssetHost(String host)Sets the host.AmqpClientOptionssetHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)Set the hostname verification algorithm interval To disable hostname verification, set hostnameVerificationAlgorithm to an empty StringAmqpClientOptionssetIdleTimeout(int idleTimeout)Set the idle timeout, default time unit is seconds.AmqpClientOptionssetIdleTimeoutUnit(TimeUnit idleTimeoutUnit)Set the idle timeout unit.AmqpClientOptionssetKeyCertOptions(KeyCertOptions options)Set the key/cert options.AmqpClientOptionssetLocalAddress(String localAddress)Set the local interface to bind for network connections.AmqpClientOptionssetMaxFrameSize(int maxFrameSize)AmqpClientOptionssetPassword(String pwd)Sets the password.AmqpClientOptionssetPort(int port)Sets the port.AmqpClientOptionssetReceiveBufferSize(int receiveBufferSize)Set the TCP receive buffer sizeAmqpClientOptionssetReconnectAttempts(int attempts)Set the value of reconnect attemptsAmqpClientOptionssetReconnectInterval(long interval)Set the reconnect intervalAmqpClientOptionssetReuseAddress(boolean reuseAddress)Set the value of reuse addressAmqpClientOptionssetReusePort(boolean reusePort)Set the value of reuse port.AmqpClientOptionssetSendBufferSize(int sendBufferSize)Set the TCP send buffer sizeAmqpClientOptionssetSniServerName(String sniServerName)AmqpClientOptionssetSoLinger(int soLinger)Set whether SO_linger keep alive is enabledAmqpClientOptionssetSsl(boolean ssl)Set whether SSL/TLS is enabledAmqpClientOptionssetSslEngineOptions(SSLEngineOptions sslEngineOptions)Set to use SSL engine implementation to use.AmqpClientOptionssetSslHandshakeTimeout(long sslHandshakeTimeout)Set the SSL handshake timeout, default time unit is seconds.AmqpClientOptionssetSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit)Set the SSL handshake timeout unit.AmqpClientOptionssetTcpCork(boolean tcpCork)Enable theTCP_CORKoption - only with linux native transport.AmqpClientOptionssetTcpFastOpen(boolean tcpFastOpen)Enable theTCP_FASTOPENoption - only with linux native transport.AmqpClientOptionssetTcpKeepAlive(boolean tcpKeepAlive)Set whether TCP keep alive is enabledAmqpClientOptionssetTcpNoDelay(boolean tcpNoDelay)Set whether TCP no delay is enabledAmqpClientOptionssetTcpQuickAck(boolean tcpQuickAck)Enable theTCP_QUICKACKoption - only with linux native transport.AmqpClientOptionssetTrafficClass(int trafficClass)Set the value of traffic classAmqpClientOptionssetTrustAll(boolean trustAll)Set whether all server certificates should be trustedAmqpClientOptionssetTrustOptions(TrustOptions options)Set the trust options.AmqpClientOptionssetUsername(String username)Sets the username.AmqpClientOptionssetVirtualHost(String virtualHost)JsonObjecttoJson()Convert to JSON-
Methods inherited from class io.vertx.proton.ProtonClientOptions
equals, getEnabledSaslMechanisms, getHeartbeat, getMaxFrameSize, getSniServerName, getVirtualHost, hashCode, setLogActivity, setMetricsName, setProxyOptions, setUseAlpn
-
Methods inherited from class io.vertx.core.net.NetClientOptions
addNonProxyHost, getApplicationLayerProtocols, getHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, isRegisterWriteHandler, removeEnabledCipherSuite, setActivityLogDataFormat, setApplicationLayerProtocols, setNonProxyHosts, setReadIdleTimeout, setRegisterWriteHandler, setWriteIdleTimeout
-
Methods inherited from class io.vertx.core.net.ClientOptionsBase
getConnectTimeout, getLocalAddress, getMetricsName, getNonProxyHosts, getOrCreateSSLOptions, getProxyOptions, getSslOptions, isTrustAll, setTcpUserTimeout
-
Methods inherited from class io.vertx.core.net.TCPSSLOptions
getCrlPaths, getCrlValues, getEnabledCipherSuites, getEnabledSecureTransportProtocols, getIdleTimeout, getIdleTimeoutUnit, getKeyCertOptions, getReadIdleTimeout, getSoLinger, getSslEngineOptions, getSslHandshakeTimeout, getSslHandshakeTimeoutUnit, getTcpUserTimeout, getTrustOptions, getWriteIdleTimeout, isSsl, isTcpCork, isTcpFastOpen, isTcpKeepAlive, isTcpNoDelay, isTcpQuickAck, isUseAlpn
-
Methods inherited from class io.vertx.core.net.NetworkOptions
getActivityLogDataFormat, getLogActivity, getReceiveBufferSize, getSendBufferSize, getTrafficClass, isReuseAddress, isReusePort
-
-
-
-
Constructor Detail
-
AmqpClientOptions
public AmqpClientOptions()
-
AmqpClientOptions
public AmqpClientOptions(JsonObject json)
-
AmqpClientOptions
public AmqpClientOptions(AmqpClientOptions other)
-
-
Method Detail
-
toJson
public JsonObject toJson()
Description copied from class:ClientOptionsBaseConvert to JSON- Overrides:
toJsonin classio.vertx.proton.ProtonClientOptions- Returns:
- the JSON
-
getHost
public String getHost()
- Returns:
- the host.
-
setHost
public AmqpClientOptions setHost(String host)
Sets the host.- Parameters:
host- the host, must not benullwhen the client attempt to connect. Defaults to system variableamqp-client-hostand toAMQP_CLIENT_HOSTenvironment variable- Returns:
- the current
AmqpClientOptions
-
getPort
public int getPort()
- Returns:
- the port.
-
setPort
public AmqpClientOptions setPort(int port)
Sets the port.- Parameters:
port- the port, defaults to system variableamqp-client-portand toAMQP_CLIENT_PORTenvironment variable and if neither is set5672.- Returns:
- the current
AmqpClientOptions
-
getUsername
public String getUsername()
- Returns:
- the username
-
setUsername
public AmqpClientOptions setUsername(String username)
Sets the username.- Parameters:
username- the username, defaults to system variableamqp-client-usernameand toAMQP_CLIENT_USERNAMEenvironment variable.- Returns:
- the current
AmqpClientOptions
-
getPassword
public String getPassword()
- Returns:
- the password
-
setPassword
public AmqpClientOptions setPassword(String pwd)
Sets the password.- Parameters:
pwd- the password, defaults to system variableamqp-client-passwordand toAMQP_CLIENT_PASSWORDenvironment variable.- Returns:
- the current
AmqpClientOptions
-
getContainerId
public String getContainerId()
- Returns:
- the container id.
-
setContainerId
public AmqpClientOptions setContainerId(String containerId)
Sets the container id.- Parameters:
containerId- the container id- Returns:
- the current
AmqpClientOptions
-
getConnectionHostname
public String getConnectionHostname()
Get the connection hostname override for the AMQP Open frame hostname- Returns:
- the hostname override
-
setConnectionHostname
public AmqpClientOptions setConnectionHostname(String hostname)
Explicitly override the hostname value used for the AMQP Open frame. The host connected to as persetHost(String)will be used in the Open frame by default.- Parameters:
hostname- the hostname override value to use as the Open frame hostname- Returns:
- current AmqpClientOptions instance
-
addEnabledSaslMechanism
public AmqpClientOptions addEnabledSaslMechanism(String saslMechanism)
- Overrides:
addEnabledSaslMechanismin classio.vertx.proton.ProtonClientOptions- See Also:
ProtonClientOptions.addEnabledSaslMechanism(String)
-
setSendBufferSize
public AmqpClientOptions setSendBufferSize(int sendBufferSize)
Description copied from class:NetworkOptionsSet the TCP send buffer size- Overrides:
setSendBufferSizein classio.vertx.proton.ProtonClientOptions- Parameters:
sendBufferSize- the buffers size, in bytes- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setSendBufferSize(int)
-
setReceiveBufferSize
public AmqpClientOptions setReceiveBufferSize(int receiveBufferSize)
Description copied from class:NetworkOptionsSet the TCP receive buffer size- Overrides:
setReceiveBufferSizein classio.vertx.proton.ProtonClientOptions- Parameters:
receiveBufferSize- the buffers size, in bytes- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setReceiveBufferSize(int)
-
setReuseAddress
public AmqpClientOptions setReuseAddress(boolean reuseAddress)
Description copied from class:NetworkOptionsSet the value of reuse address- Overrides:
setReuseAddressin classio.vertx.proton.ProtonClientOptions- Parameters:
reuseAddress- the value of reuse address- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setReuseAddress(boolean)
-
setTrafficClass
public AmqpClientOptions setTrafficClass(int trafficClass)
Description copied from class:NetworkOptionsSet the value of traffic class- Overrides:
setTrafficClassin classio.vertx.proton.ProtonClientOptions- Parameters:
trafficClass- the value of traffic class- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setTrafficClass(int)
-
setTcpNoDelay
public AmqpClientOptions setTcpNoDelay(boolean tcpNoDelay)
Description copied from class:TCPSSLOptionsSet whether TCP no delay is enabled- Overrides:
setTcpNoDelayin classio.vertx.proton.ProtonClientOptions- Parameters:
tcpNoDelay- true if TCP no delay is enabled (Nagle disabled)- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setTcpNoDelay(boolean)
-
setTcpKeepAlive
public AmqpClientOptions setTcpKeepAlive(boolean tcpKeepAlive)
Description copied from class:TCPSSLOptionsSet whether TCP keep alive is enabled- Overrides:
setTcpKeepAlivein classio.vertx.proton.ProtonClientOptions- Parameters:
tcpKeepAlive- true if TCP keep alive is enabled- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setTcpKeepAlive(boolean)
-
setSoLinger
public AmqpClientOptions setSoLinger(int soLinger)
Description copied from class:TCPSSLOptionsSet whether SO_linger keep alive is enabled- Overrides:
setSoLingerin classio.vertx.proton.ProtonClientOptions- Parameters:
soLinger- true if SO_linger is enabled- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setSoLinger(int)
-
setIdleTimeout
public AmqpClientOptions setIdleTimeout(int idleTimeout)
Description copied from class:TCPSSLOptionsSet the idle timeout, default time unit is seconds. Zero means don't timeout. This determines if a connection will timeout and be closed if no data is received nor sent within the timeout. If you want change default time unit, useTCPSSLOptions.setIdleTimeoutUnit(TimeUnit)- Overrides:
setIdleTimeoutin classio.vertx.proton.ProtonClientOptions- Parameters:
idleTimeout- the timeout- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setIdleTimeout(int)
-
setIdleTimeoutUnit
public AmqpClientOptions setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
Description copied from class:TCPSSLOptionsSet the idle timeout unit. If not specified, default is seconds.- Overrides:
setIdleTimeoutUnitin classio.vertx.proton.ProtonClientOptions- Parameters:
idleTimeoutUnit- specify time unit.- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setIdleTimeoutUnit(TimeUnit)
-
setSsl
public AmqpClientOptions setSsl(boolean ssl)
Description copied from class:TCPSSLOptionsSet whether SSL/TLS is enabled- Overrides:
setSslin classio.vertx.proton.ProtonClientOptions- Parameters:
ssl- true if enabled- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setSsl(boolean)
-
setSslHandshakeTimeout
public AmqpClientOptions setSslHandshakeTimeout(long sslHandshakeTimeout)
Description copied from class:TCPSSLOptionsSet the SSL handshake timeout, default time unit is seconds.- Overrides:
setSslHandshakeTimeoutin classio.vertx.proton.ProtonClientOptions- Parameters:
sslHandshakeTimeout- the SSL handshake timeout to set, in milliseconds- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions#setSslHandshakeTimeout(boolean)
-
setSslHandshakeTimeoutUnit
public AmqpClientOptions setSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit)
Description copied from class:TCPSSLOptionsSet the SSL handshake timeout unit. If not specified, default is seconds.- Overrides:
setSslHandshakeTimeoutUnitin classio.vertx.proton.ProtonClientOptions- Parameters:
sslHandshakeTimeoutUnit- specify time unit.- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setSslHandshakeTimeoutUnit(TimeUnit)
-
setKeyCertOptions
public AmqpClientOptions setKeyCertOptions(KeyCertOptions options)
Description copied from class:TCPSSLOptionsSet the key/cert options.- Overrides:
setKeyCertOptionsin classio.vertx.proton.ProtonClientOptions- Parameters:
options- the key store options- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setKeyCertOptions(KeyCertOptions)
-
setTrustOptions
public AmqpClientOptions setTrustOptions(TrustOptions options)
Description copied from class:TCPSSLOptionsSet the trust options.- Overrides:
setTrustOptionsin classio.vertx.proton.ProtonClientOptions- Parameters:
options- the trust options- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setTrustOptions(TrustOptions)
-
addEnabledCipherSuite
public AmqpClientOptions addEnabledCipherSuite(String suite)
Description copied from class:TCPSSLOptionsAdd an enabled cipher suite, appended to the ordered suites.- Overrides:
addEnabledCipherSuitein classio.vertx.proton.ProtonClientOptions- Parameters:
suite- the suite- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.addEnabledCipherSuite(String)
-
addCrlPath
public AmqpClientOptions addCrlPath(String crlPath)
Description copied from class:TCPSSLOptionsAdd a CRL path- Overrides:
addCrlPathin classio.vertx.proton.ProtonClientOptions- Parameters:
crlPath- the path- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.addCrlPath(String)
-
addCrlValue
public AmqpClientOptions addCrlValue(Buffer crlValue)
Description copied from class:TCPSSLOptionsAdd a CRL value- Overrides:
addCrlValuein classio.vertx.proton.ProtonClientOptions- Parameters:
crlValue- the value- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.addCrlValue(Buffer)
-
setTrustAll
public AmqpClientOptions setTrustAll(boolean trustAll)
Description copied from class:ClientOptionsBaseSet whether all server certificates should be trusted- Overrides:
setTrustAllin classio.vertx.proton.ProtonClientOptions- Parameters:
trustAll- true if all should be trusted- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setTrustAll(boolean)
-
setConnectTimeout
public AmqpClientOptions setConnectTimeout(int connectTimeout)
Description copied from class:ClientOptionsBaseSet the connect timeout- Overrides:
setConnectTimeoutin classio.vertx.proton.ProtonClientOptions- Parameters:
connectTimeout- connect timeout, in ms- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setConnectTimeout(int)
-
setReconnectAttempts
public AmqpClientOptions setReconnectAttempts(int attempts)
Description copied from class:NetClientOptionsSet the value of reconnect attempts- Overrides:
setReconnectAttemptsin classio.vertx.proton.ProtonClientOptions- Parameters:
attempts- the maximum number of reconnect attempts- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setReconnectAttempts(int)
-
setReconnectInterval
public AmqpClientOptions setReconnectInterval(long interval)
Description copied from class:NetClientOptionsSet the reconnect interval- Overrides:
setReconnectIntervalin classio.vertx.proton.ProtonClientOptions- Parameters:
interval- the reconnect interval in ms- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setReconnectInterval(long)
-
addEnabledSecureTransportProtocol
public AmqpClientOptions addEnabledSecureTransportProtocol(String protocol)
Description copied from class:TCPSSLOptionsAdd an enabled SSL/TLS protocols, appended to the ordered protocols.- Overrides:
addEnabledSecureTransportProtocolin classio.vertx.proton.ProtonClientOptions- Parameters:
protocol- the SSL/TLS protocol to enable- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.addEnabledSecureTransportProtocol(String)
-
setHostnameVerificationAlgorithm
public AmqpClientOptions setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
Description copied from class:NetClientOptionsSet the hostname verification algorithm interval To disable hostname verification, set hostnameVerificationAlgorithm to an empty String- Overrides:
setHostnameVerificationAlgorithmin classio.vertx.proton.ProtonClientOptions- Parameters:
hostnameVerificationAlgorithm- should be HTTPS, LDAPS or an empty String- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setHostnameVerificationAlgorithm(String)
-
setSslEngineOptions
public AmqpClientOptions setSslEngineOptions(SSLEngineOptions sslEngineOptions)
Description copied from class:TCPSSLOptionsSet to use SSL engine implementation to use.- Overrides:
setSslEngineOptionsin classio.vertx.proton.ProtonClientOptions- Parameters:
sslEngineOptions- the ssl engine to use- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setSslEngineOptions(SSLEngineOptions)
-
setLocalAddress
public AmqpClientOptions setLocalAddress(String localAddress)
Description copied from class:ClientOptionsBaseSet the local interface to bind for network connections. When the local address is null, it will pick any local address, the default local address is null.- Overrides:
setLocalAddressin classio.vertx.proton.ProtonClientOptions- Parameters:
localAddress- the local address- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setLocalAddress(String)
-
setReusePort
public AmqpClientOptions setReusePort(boolean reusePort)
Description copied from class:NetworkOptionsSet the value of reuse port. This is only supported by native transports.- Overrides:
setReusePortin classio.vertx.proton.ProtonClientOptions- Parameters:
reusePort- the value of reuse port- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setReusePort(boolean)
-
setTcpCork
public AmqpClientOptions setTcpCork(boolean tcpCork)
Description copied from class:TCPSSLOptionsEnable theTCP_CORKoption - only with linux native transport.- Overrides:
setTcpCorkin classio.vertx.proton.ProtonClientOptions- Parameters:
tcpCork- the cork value- See Also:
ProtonClientOptions.setTcpCork(boolean)
-
setTcpFastOpen
public AmqpClientOptions setTcpFastOpen(boolean tcpFastOpen)
Description copied from class:TCPSSLOptionsEnable theTCP_FASTOPENoption - only with linux native transport.- Overrides:
setTcpFastOpenin classio.vertx.proton.ProtonClientOptions- Parameters:
tcpFastOpen- the fast open value- See Also:
ProtonClientOptions.setTcpFastOpen(boolean)
-
setTcpQuickAck
public AmqpClientOptions setTcpQuickAck(boolean tcpQuickAck)
Description copied from class:TCPSSLOptionsEnable theTCP_QUICKACKoption - only with linux native transport.- Overrides:
setTcpQuickAckin classio.vertx.proton.ProtonClientOptions- Parameters:
tcpQuickAck- the quick ack value- See Also:
ProtonClientOptions.setTcpQuickAck(boolean)
-
removeEnabledSecureTransportProtocol
public AmqpClientOptions removeEnabledSecureTransportProtocol(String protocol)
Description copied from class:TCPSSLOptionsRemoves an enabled SSL/TLS protocol from the ordered protocols.- Overrides:
removeEnabledSecureTransportProtocolin classio.vertx.proton.ProtonClientOptions- Parameters:
protocol- the SSL/TLS protocol to disable- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.removeEnabledSecureTransportProtocol(String)
-
setEnabledSecureTransportProtocols
public AmqpClientOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
Description copied from class:TCPSSLOptionsSets the list of enabled SSL/TLS protocols.- Overrides:
setEnabledSecureTransportProtocolsin classio.vertx.proton.ProtonClientOptions- Parameters:
enabledSecureTransportProtocols- the SSL/TLS protocols to enable- Returns:
- a reference to this, so the API can be used fluently
- See Also:
ProtonClientOptions.setEnabledSecureTransportProtocols(Set)
-
setVirtualHost
public AmqpClientOptions setVirtualHost(String virtualHost)
- Overrides:
setVirtualHostin classio.vertx.proton.ProtonClientOptions- See Also:
ProtonClientOptions.setVirtualHost(String)
-
setSniServerName
public AmqpClientOptions setSniServerName(String sniServerName)
- Overrides:
setSniServerNamein classio.vertx.proton.ProtonClientOptions- See Also:
ProtonClientOptions.setSniServerName(String)
-
setHeartbeat
public AmqpClientOptions setHeartbeat(int heartbeat)
- Overrides:
setHeartbeatin classio.vertx.proton.ProtonClientOptions- See Also:
ProtonClientOptions.setHeartbeat(int)
-
setMaxFrameSize
public AmqpClientOptions setMaxFrameSize(int maxFrameSize)
- Overrides:
setMaxFrameSizein classio.vertx.proton.ProtonClientOptions- See Also:
ProtonClientOptions.setMaxFrameSize(int)
-
-