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
Constructor and Description |
---|
AmqpClientOptions() |
AmqpClientOptions(AmqpClientOptions other) |
AmqpClientOptions(io.vertx.core.json.JsonObject json) |
equals, getEnabledSaslMechanisms, getHeartbeat, getMaxFrameSize, getSniServerName, getVirtualHost, hashCode, setLogActivity, setMetricsName, setProxyOptions, setUseAlpn
addNonProxyHost, getApplicationLayerProtocols, getHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, setApplicationLayerProtocols, setNonProxyHosts
getConnectTimeout, getLocalAddress, getMetricsName, getNonProxyHosts, 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
public AmqpClientOptions()
public AmqpClientOptions(io.vertx.core.json.JsonObject json)
public AmqpClientOptions(AmqpClientOptions other)
public io.vertx.core.json.JsonObject toJson()
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)
setSendBufferSize
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setSendBufferSize(int)
public AmqpClientOptions setReceiveBufferSize(int receiveBufferSize)
setReceiveBufferSize
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setReceiveBufferSize(int)
public AmqpClientOptions setReuseAddress(boolean reuseAddress)
setReuseAddress
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setReuseAddress(boolean)
public AmqpClientOptions setTrafficClass(int trafficClass)
setTrafficClass
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTrafficClass(int)
public AmqpClientOptions setTcpNoDelay(boolean tcpNoDelay)
setTcpNoDelay
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTcpNoDelay(boolean)
public AmqpClientOptions setTcpKeepAlive(boolean tcpKeepAlive)
setTcpKeepAlive
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTcpKeepAlive(boolean)
public AmqpClientOptions setSoLinger(int soLinger)
setSoLinger
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setSoLinger(int)
public AmqpClientOptions setIdleTimeout(int idleTimeout)
setIdleTimeout
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setIdleTimeout(int)
public AmqpClientOptions setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
setIdleTimeoutUnit
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setIdleTimeoutUnit(TimeUnit)
public AmqpClientOptions setSsl(boolean ssl)
setSsl
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setSsl(boolean)
public AmqpClientOptions setSslHandshakeTimeout(long sslHandshakeTimeout)
setSslHandshakeTimeout
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions#setSslHandshakeTimeout(boolean)
public AmqpClientOptions setSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit)
setSslHandshakeTimeoutUnit
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setSslHandshakeTimeoutUnit(TimeUnit)
public AmqpClientOptions setKeyStoreOptions(io.vertx.core.net.JksOptions options)
setKeyStoreOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setKeyStoreOptions(JksOptions)
public AmqpClientOptions setKeyCertOptions(io.vertx.core.net.KeyCertOptions options)
setKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions#setKeyCertOptions(PfxOptions)
public AmqpClientOptions setPfxKeyCertOptions(io.vertx.core.net.PfxOptions options)
setPfxKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setPfxKeyCertOptions(PfxOptions)
public AmqpClientOptions setPemKeyCertOptions(io.vertx.core.net.PemKeyCertOptions options)
setPemKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setPemKeyCertOptions(PemKeyCertOptions)
public AmqpClientOptions setTrustOptions(io.vertx.core.net.TrustOptions options)
setTrustOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions#setTrustStoreOptions(TrustOptions)
public AmqpClientOptions setTrustStoreOptions(io.vertx.core.net.JksOptions options)
setTrustStoreOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTrustStoreOptions(JksOptions)
public AmqpClientOptions setPemTrustOptions(io.vertx.core.net.PemTrustOptions options)
setPemTrustOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setPemTrustOptions(PemTrustOptions)
public AmqpClientOptions setPfxTrustOptions(io.vertx.core.net.PfxOptions options)
setPfxTrustOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setPfxTrustOptions(PfxOptions)
public AmqpClientOptions addEnabledCipherSuite(String suite)
addEnabledCipherSuite
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.addEnabledCipherSuite(String)
public AmqpClientOptions addCrlPath(String crlPath)
addCrlPath
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.addCrlPath(String)
public AmqpClientOptions addCrlValue(io.vertx.core.buffer.Buffer crlValue)
addCrlValue
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.addCrlValue(Buffer)
public AmqpClientOptions setTrustAll(boolean trustAll)
setTrustAll
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTrustAll(boolean)
public AmqpClientOptions setConnectTimeout(int connectTimeout)
setConnectTimeout
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setConnectTimeout(int)
public AmqpClientOptions setReconnectAttempts(int attempts)
setReconnectAttempts
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setReconnectAttempts(int)
public AmqpClientOptions setReconnectInterval(long interval)
setReconnectInterval
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setReconnectInterval(long)
public AmqpClientOptions addEnabledSecureTransportProtocol(String protocol)
addEnabledSecureTransportProtocol
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.addEnabledSecureTransportProtocol(String)
public AmqpClientOptions setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
setHostnameVerificationAlgorithm
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setHostnameVerificationAlgorithm(String)
public AmqpClientOptions setJdkSslEngineOptions(io.vertx.core.net.JdkSSLEngineOptions sslEngineOptions)
setJdkSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setJdkSslEngineOptions(JdkSSLEngineOptions)
public AmqpClientOptions setOpenSslEngineOptions(io.vertx.core.net.OpenSSLEngineOptions sslEngineOptions)
setOpenSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setOpenSslEngineOptions(OpenSSLEngineOptions)
public AmqpClientOptions setSslEngineOptions(io.vertx.core.net.SSLEngineOptions sslEngineOptions)
setSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setSslEngineOptions(SSLEngineOptions)
public AmqpClientOptions setLocalAddress(String localAddress)
setLocalAddress
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setLocalAddress(String)
public AmqpClientOptions setReusePort(boolean reusePort)
setReusePort
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setReusePort(boolean)
public AmqpClientOptions setTcpCork(boolean tcpCork)
setTcpCork
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTcpCork(boolean)
public AmqpClientOptions setTcpFastOpen(boolean tcpFastOpen)
setTcpFastOpen
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTcpFastOpen(boolean)
public AmqpClientOptions setTcpQuickAck(boolean tcpQuickAck)
setTcpQuickAck
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.setTcpQuickAck(boolean)
public AmqpClientOptions removeEnabledSecureTransportProtocol(String protocol)
removeEnabledSecureTransportProtocol
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.removeEnabledSecureTransportProtocol(String)
public AmqpClientOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
setEnabledSecureTransportProtocols
in class io.vertx.proton.ProtonClientOptions
ProtonClientOptions.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 © 2022 Eclipse. All rights reserved.