public class AmqpBridgeOptions
extends io.vertx.proton.ProtonClientOptions
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_TCP_USER_TIMEOUT, DEFAULT_USE_ALPN, DEFAULT_USE_POOLED_BUFFERS
DEFAULT_LOG_ENABLED, DEFAULT_RECEIVE_BUFFER_SIZE, DEFAULT_REUSE_ADDRESS, DEFAULT_REUSE_PORT, DEFAULT_SEND_BUFFER_SIZE, DEFAULT_TRAFFIC_CLASS
Constructor and Description |
---|
AmqpBridgeOptions() |
AmqpBridgeOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
AmqpBridgeOptions |
addCrlPath(String crlPath)
Add a CRL path
|
AmqpBridgeOptions |
addCrlValue(Buffer crlValue)
Add a CRL value
|
AmqpBridgeOptions |
addEnabledCipherSuite(String suite)
Add an enabled cipher suite, appended to the ordered suites.
|
AmqpBridgeOptions |
addEnabledSaslMechanism(String saslMechanism) |
AmqpBridgeOptions |
addEnabledSecureTransportProtocol(String protocol)
Add an enabled SSL/TLS protocols, appended to the ordered protocols.
|
boolean |
equals(Object obj) |
String |
getContainerId()
Gets the value to use as the container-id field in the AMQP Open frame.
|
String |
getVhost()
Deprecated.
use
ProtonClientOptions.getVirtualHost() option instead. |
int |
hashCode() |
boolean |
isReplyHandlingSupport()
Whether the bridge should try to enable support for sending messages with a reply handler set, and replying to
messages using the message reply methods.
|
AmqpBridgeOptions |
removeEnabledSecureTransportProtocol(String protocol)
Removes an enabled SSL/TLS protocol from the ordered protocols.
|
AmqpBridgeOptions |
setConnectTimeout(int connectTimeout)
Set the connect timeout
|
AmqpBridgeOptions |
setContainerId(String containerId)
Sets the value to use as the container-id field in the AMQP Open frame.
|
AmqpBridgeOptions |
setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
Sets the list of enabled SSL/TLS protocols.
|
AmqpBridgeOptions |
setHeartbeat(int heartbeat) |
AmqpBridgeOptions |
setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
Set the hostname verification algorithm interval
To disable hostname verification, set hostnameVerificationAlgorithm to an empty String
|
AmqpBridgeOptions |
setIdleTimeout(int idleTimeout)
Set the idle timeout, default time unit is seconds.
|
AmqpBridgeOptions |
setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
Set the idle timeout unit.
|
AmqpBridgeOptions |
setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions) |
AmqpBridgeOptions |
setKeyCertOptions(KeyCertOptions options)
Set the key/cert options.
|
AmqpBridgeOptions |
setKeyStoreOptions(JksOptions options)
Set the key/cert options in jks format, aka Java keystore.
|
AmqpBridgeOptions |
setLocalAddress(String localAddress)
Set the local interface to bind for network connections.
|
AmqpBridgeOptions |
setLogActivity(boolean logEnabled)
Set to true to enabled network activity logging: Netty's pipeline is configured for logging on Netty's logger.
|
AmqpBridgeOptions |
setMaxFrameSize(int maxFrameSize) |
AmqpBridgeOptions |
setMetricsName(String metricsName)
Set the metrics name identifying the reported metrics, useful for grouping metrics
with the same name.
|
AmqpBridgeOptions |
setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions) |
AmqpBridgeOptions |
setPemKeyCertOptions(PemKeyCertOptions options)
Set the key/cert store options in pem format.
|
AmqpBridgeOptions |
setPemTrustOptions(PemTrustOptions options)
Set the trust options in pem format
|
AmqpBridgeOptions |
setPfxKeyCertOptions(PfxOptions options)
Set the key/cert options in pfx format.
|
AmqpBridgeOptions |
setPfxTrustOptions(PfxOptions options)
Set the trust options in pfx format
|
AmqpBridgeOptions |
setProxyOptions(ProxyOptions proxyOptions)
Set proxy options for connections via CONNECT proxy (e.g.
|
AmqpBridgeOptions |
setReceiveBufferSize(int receiveBufferSize)
Set the TCP receive buffer size
|
AmqpBridgeOptions |
setReconnectAttempts(int attempts)
Set the value of reconnect attempts
|
AmqpBridgeOptions |
setReconnectInterval(long interval)
Set the reconnect interval
|
AmqpBridgeOptions |
setReplyHandlingSupport(boolean replyHandlingSupport)
Sets whether the bridge should try to enable support for sending messages with a reply handler set, and replying to
messages using the message reply methods.
|
AmqpBridgeOptions |
setReuseAddress(boolean reuseAddress)
Set the value of reuse address
|
AmqpBridgeOptions |
setReusePort(boolean reusePort)
Set the value of reuse port.
|
AmqpBridgeOptions |
setSendBufferSize(int sendBufferSize)
Set the TCP send buffer size
|
AmqpBridgeOptions |
setSniServerName(String sniServerName) |
AmqpBridgeOptions |
setSoLinger(int soLinger)
Set whether SO_linger keep alive is enabled
|
AmqpBridgeOptions |
setSsl(boolean ssl)
Set whether SSL/TLS is enabled
|
AmqpBridgeOptions |
setSslEngineOptions(SSLEngineOptions sslEngineOptions)
Set to use SSL engine implementation to use.
|
AmqpBridgeOptions |
setTcpCork(boolean tcpCork)
Enable the
TCP_CORK option - only with linux native transport. |
AmqpBridgeOptions |
setTcpFastOpen(boolean tcpFastOpen)
Enable the
TCP_FASTOPEN option - only with linux native transport. |
AmqpBridgeOptions |
setTcpKeepAlive(boolean tcpKeepAlive)
Set whether TCP keep alive is enabled
|
AmqpBridgeOptions |
setTcpNoDelay(boolean tcpNoDelay)
Set whether TCP no delay is enabled
|
AmqpBridgeOptions |
setTcpQuickAck(boolean tcpQuickAck)
Enable the
TCP_QUICKACK option - only with linux native transport. |
AmqpBridgeOptions |
setTrafficClass(int trafficClass)
Set the value of traffic class
|
AmqpBridgeOptions |
setTrustAll(boolean trustAll)
Set whether all server certificates should be trusted
|
AmqpBridgeOptions |
setTrustOptions(TrustOptions options)
Set the trust options.
|
AmqpBridgeOptions |
setTrustStoreOptions(JksOptions options)
Set the trust options in jks format, aka Java truststore
|
AmqpBridgeOptions |
setUseAlpn(boolean useAlpn)
Set the ALPN usage.
|
AmqpBridgeOptions |
setUsePooledBuffers(boolean usePooledBuffers)
Set whether Netty pooled buffers are enabled
|
AmqpBridgeOptions |
setVhost(String vhost)
Deprecated.
use
setVirtualHost(String) option instead. |
AmqpBridgeOptions |
setVirtualHost(String virtualHost) |
JsonObject |
toJson()
Convert to JSON
|
getEnabledSaslMechanisms, getHeartbeat, getMaxFrameSize, getSniServerName, getVirtualHost
getHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, setSslHandshakeTimeout, setSslHandshakeTimeoutUnit
getConnectTimeout, getLocalAddress, getMetricsName, getProxyOptions, isTrustAll, setTcpUserTimeout
getCrlPaths, getCrlValues, getEnabledCipherSuites, getEnabledSecureTransportProtocols, getIdleTimeout, getIdleTimeoutUnit, getJdkSslEngineOptions, getKeyCertOptions, getKeyStoreOptions, getOpenSslEngineOptions, getPemKeyCertOptions, getPemTrustOptions, getPfxKeyCertOptions, getPfxTrustOptions, getSoLinger, getSslEngineOptions, getSslHandshakeTimeout, getSslHandshakeTimeoutUnit, getTcpUserTimeout, getTrustOptions, getTrustStoreOptions, isSsl, isTcpCork, isTcpFastOpen, isTcpKeepAlive, isTcpNoDelay, isTcpQuickAck, isUseAlpn, isUsePooledBuffers
getLogActivity, getReceiveBufferSize, getSendBufferSize, getTrafficClass, isReuseAddress, isReusePort
public AmqpBridgeOptions()
public AmqpBridgeOptions(JsonObject json)
public JsonObject toJson()
ClientOptionsBase
toJson
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setContainerId(String containerId)
containerId
- the container-id to usepublic String getContainerId()
@Deprecated public AmqpBridgeOptions setVhost(String vhost)
setVirtualHost(String)
option instead.vhost
- the value to use as the hostname field in the AMQP Open frame to indicate a vhost.@Deprecated public String getVhost()
ProtonClientOptions.getVirtualHost()
option instead.public AmqpBridgeOptions setReplyHandlingSupport(boolean replyHandlingSupport)
replyHandlingSupport
- should attempt be made to enable support for sending messages with a reply handlerpublic boolean isReplyHandlingSupport()
public AmqpBridgeOptions addEnabledSaslMechanism(String saslMechanism)
addEnabledSaslMechanism
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setHeartbeat(int heartbeat)
setHeartbeat
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setSendBufferSize(int sendBufferSize)
NetworkOptions
setSendBufferSize
in class io.vertx.proton.ProtonClientOptions
sendBufferSize
- the buffers size, in bytespublic AmqpBridgeOptions setReceiveBufferSize(int receiveBufferSize)
NetworkOptions
setReceiveBufferSize
in class io.vertx.proton.ProtonClientOptions
receiveBufferSize
- the buffers size, in bytespublic AmqpBridgeOptions setReuseAddress(boolean reuseAddress)
NetworkOptions
setReuseAddress
in class io.vertx.proton.ProtonClientOptions
reuseAddress
- the value of reuse addresspublic AmqpBridgeOptions setTrafficClass(int trafficClass)
NetworkOptions
setTrafficClass
in class io.vertx.proton.ProtonClientOptions
trafficClass
- the value of traffic classpublic AmqpBridgeOptions setTcpNoDelay(boolean tcpNoDelay)
TCPSSLOptions
setTcpNoDelay
in class io.vertx.proton.ProtonClientOptions
tcpNoDelay
- true if TCP no delay is enabled (Nagle disabled)public AmqpBridgeOptions setTcpKeepAlive(boolean tcpKeepAlive)
TCPSSLOptions
setTcpKeepAlive
in class io.vertx.proton.ProtonClientOptions
tcpKeepAlive
- true if TCP keep alive is enabledpublic AmqpBridgeOptions setSoLinger(int soLinger)
TCPSSLOptions
setSoLinger
in class io.vertx.proton.ProtonClientOptions
soLinger
- true if SO_linger is enabledpublic AmqpBridgeOptions setReusePort(boolean reusePort)
NetworkOptions
setReusePort
in class io.vertx.proton.ProtonClientOptions
reusePort
- the value of reuse portpublic AmqpBridgeOptions setTcpCork(boolean tcpCork)
TCPSSLOptions
TCP_CORK
option - only with linux native transport.setTcpCork
in class io.vertx.proton.ProtonClientOptions
tcpCork
- the cork valuepublic AmqpBridgeOptions setTcpFastOpen(boolean tcpFastOpen)
TCPSSLOptions
TCP_FASTOPEN
option - only with linux native transport.setTcpFastOpen
in class io.vertx.proton.ProtonClientOptions
tcpFastOpen
- the fast open valuepublic AmqpBridgeOptions setTcpQuickAck(boolean tcpQuickAck)
TCPSSLOptions
TCP_QUICKACK
option - only with linux native transport.setTcpQuickAck
in class io.vertx.proton.ProtonClientOptions
tcpQuickAck
- the quick ack valuepublic AmqpBridgeOptions setUsePooledBuffers(boolean usePooledBuffers)
TCPSSLOptions
setUsePooledBuffers
in class io.vertx.proton.ProtonClientOptions
usePooledBuffers
- true if pooled buffers enabledpublic AmqpBridgeOptions setIdleTimeout(int idleTimeout)
TCPSSLOptions
TCPSSLOptions.setIdleTimeoutUnit(TimeUnit)
setIdleTimeout
in class io.vertx.proton.ProtonClientOptions
idleTimeout
- the timeout, in secondspublic AmqpBridgeOptions setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
TCPSSLOptions
setIdleTimeoutUnit
in class io.vertx.proton.ProtonClientOptions
idleTimeoutUnit
- specify time unit.public AmqpBridgeOptions setSsl(boolean ssl)
TCPSSLOptions
setSsl
in class io.vertx.proton.ProtonClientOptions
ssl
- true if enabledpublic AmqpBridgeOptions setKeyStoreOptions(JksOptions options)
TCPSSLOptions
setKeyStoreOptions
in class io.vertx.proton.ProtonClientOptions
options
- the key store in jks formatpublic AmqpBridgeOptions setPfxKeyCertOptions(PfxOptions options)
TCPSSLOptions
setPfxKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
options
- the key cert options in pfx formatpublic AmqpBridgeOptions setPemKeyCertOptions(PemKeyCertOptions options)
TCPSSLOptions
setPemKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
options
- the options in pem formatpublic AmqpBridgeOptions setTrustStoreOptions(JksOptions options)
TCPSSLOptions
setTrustStoreOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust options in jks formatpublic AmqpBridgeOptions setPemTrustOptions(PemTrustOptions options)
TCPSSLOptions
setPemTrustOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust options in pem formatpublic AmqpBridgeOptions setPfxTrustOptions(PfxOptions options)
TCPSSLOptions
setPfxTrustOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust options in pfx formatpublic AmqpBridgeOptions addEnabledCipherSuite(String suite)
TCPSSLOptions
addEnabledCipherSuite
in class io.vertx.proton.ProtonClientOptions
suite
- the suitepublic AmqpBridgeOptions addCrlPath(String crlPath) throws NullPointerException
TCPSSLOptions
addCrlPath
in class io.vertx.proton.ProtonClientOptions
crlPath
- the pathNullPointerException
public AmqpBridgeOptions addCrlValue(Buffer crlValue) throws NullPointerException
TCPSSLOptions
addCrlValue
in class io.vertx.proton.ProtonClientOptions
crlValue
- the valueNullPointerException
public AmqpBridgeOptions setTrustAll(boolean trustAll)
ClientOptionsBase
setTrustAll
in class io.vertx.proton.ProtonClientOptions
trustAll
- true if all should be trustedpublic AmqpBridgeOptions setConnectTimeout(int connectTimeout)
ClientOptionsBase
setConnectTimeout
in class io.vertx.proton.ProtonClientOptions
connectTimeout
- connect timeout, in mspublic AmqpBridgeOptions setReconnectAttempts(int attempts)
NetClientOptions
setReconnectAttempts
in class io.vertx.proton.ProtonClientOptions
attempts
- the maximum number of reconnect attemptspublic AmqpBridgeOptions setReconnectInterval(long interval)
NetClientOptions
setReconnectInterval
in class io.vertx.proton.ProtonClientOptions
interval
- the reconnect interval in mspublic AmqpBridgeOptions setUseAlpn(boolean useAlpn)
TCPSSLOptions
setUseAlpn
in class io.vertx.proton.ProtonClientOptions
useAlpn
- true when Application-Layer Protocol Negotiation should be usedpublic AmqpBridgeOptions addEnabledSecureTransportProtocol(String protocol)
TCPSSLOptions
addEnabledSecureTransportProtocol
in class io.vertx.proton.ProtonClientOptions
protocol
- the SSL/TLS protocol to enablepublic AmqpBridgeOptions removeEnabledSecureTransportProtocol(String protocol)
TCPSSLOptions
removeEnabledSecureTransportProtocol
in class io.vertx.proton.ProtonClientOptions
protocol
- the SSL/TLS protocol to disablepublic AmqpBridgeOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
TCPSSLOptions
setEnabledSecureTransportProtocols
in class io.vertx.proton.ProtonClientOptions
enabledSecureTransportProtocols
- the SSL/TLS protocols to enablepublic AmqpBridgeOptions setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
NetClientOptions
setHostnameVerificationAlgorithm
in class io.vertx.proton.ProtonClientOptions
hostnameVerificationAlgorithm
- should be HTTPS, LDAPS or an empty Stringpublic AmqpBridgeOptions setKeyCertOptions(KeyCertOptions options)
TCPSSLOptions
setKeyCertOptions
in class io.vertx.proton.ProtonClientOptions
options
- the key store optionspublic AmqpBridgeOptions setLogActivity(boolean logEnabled)
NetworkOptions
setLogActivity
in class io.vertx.proton.ProtonClientOptions
logEnabled
- true for logging the network activitypublic AmqpBridgeOptions setMetricsName(String metricsName)
ClientOptionsBase
setMetricsName
in class io.vertx.proton.ProtonClientOptions
metricsName
- the metrics namepublic AmqpBridgeOptions setProxyOptions(ProxyOptions proxyOptions)
ClientOptionsBase
setProxyOptions
in class io.vertx.proton.ProtonClientOptions
proxyOptions
- proxy options objectpublic AmqpBridgeOptions setTrustOptions(TrustOptions options)
TCPSSLOptions
setTrustOptions
in class io.vertx.proton.ProtonClientOptions
options
- the trust optionspublic AmqpBridgeOptions setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions)
setJdkSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions)
setOpenSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setSslEngineOptions(SSLEngineOptions sslEngineOptions)
TCPSSLOptions
setSslEngineOptions
in class io.vertx.proton.ProtonClientOptions
sslEngineOptions
- the ssl engine to usepublic AmqpBridgeOptions setLocalAddress(String localAddress)
ClientOptionsBase
setLocalAddress
in class io.vertx.proton.ProtonClientOptions
localAddress
- the local addresspublic int hashCode()
hashCode
in class io.vertx.proton.ProtonClientOptions
public boolean equals(Object obj)
equals
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setVirtualHost(String virtualHost)
setVirtualHost
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setSniServerName(String sniServerName)
setSniServerName
in class io.vertx.proton.ProtonClientOptions
public AmqpBridgeOptions setMaxFrameSize(int maxFrameSize)
setMaxFrameSize
in class io.vertx.proton.ProtonClientOptions
Copyright © 2023 Eclipse. All rights reserved.