public class AmqpBridgeOptions
extends io.vertx.proton.ProtonClientOptions
DEFAULT_HOSTNAME_VERIFICATION_ALGORITHM, DEFAULT_RECONNECT_ATTEMPTS, DEFAULT_RECONNECT_INTERVALDEFAULT_CONNECT_TIMEOUT, DEFAULT_METRICS_NAME, DEFAULT_TRUST_ALLDEFAULT_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_USE_POOLED_BUFFERSDEFAULT_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, getVirtualHostgetHostnameVerificationAlgorithm, getReconnectAttempts, getReconnectInterval, setSslHandshakeTimeout, setSslHandshakeTimeoutUnitgetConnectTimeout, getLocalAddress, getMetricsName, getProxyOptions, isTrustAllgetCrlPaths, 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, isUsePooledBuffersgetLogActivity, getReceiveBufferSize, getSendBufferSize, getTrafficClass, isReuseAddress, isReusePortpublic AmqpBridgeOptions()
public AmqpBridgeOptions(JsonObject json)
public JsonObject toJson()
ClientOptionsBasetoJson in class io.vertx.proton.ProtonClientOptionspublic 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.ProtonClientOptionspublic AmqpBridgeOptions setHeartbeat(int heartbeat)
setHeartbeat in class io.vertx.proton.ProtonClientOptionspublic AmqpBridgeOptions setSendBufferSize(int sendBufferSize)
NetworkOptionssetSendBufferSize in class io.vertx.proton.ProtonClientOptionssendBufferSize - the buffers size, in bytespublic AmqpBridgeOptions setReceiveBufferSize(int receiveBufferSize)
NetworkOptionssetReceiveBufferSize in class io.vertx.proton.ProtonClientOptionsreceiveBufferSize - the buffers size, in bytespublic AmqpBridgeOptions setReuseAddress(boolean reuseAddress)
NetworkOptionssetReuseAddress in class io.vertx.proton.ProtonClientOptionsreuseAddress - the value of reuse addresspublic AmqpBridgeOptions setTrafficClass(int trafficClass)
NetworkOptionssetTrafficClass in class io.vertx.proton.ProtonClientOptionstrafficClass - the value of traffic classpublic AmqpBridgeOptions setTcpNoDelay(boolean tcpNoDelay)
TCPSSLOptionssetTcpNoDelay in class io.vertx.proton.ProtonClientOptionstcpNoDelay - true if TCP no delay is enabled (Nagle disabled)public AmqpBridgeOptions setTcpKeepAlive(boolean tcpKeepAlive)
TCPSSLOptionssetTcpKeepAlive in class io.vertx.proton.ProtonClientOptionstcpKeepAlive - true if TCP keep alive is enabledpublic AmqpBridgeOptions setSoLinger(int soLinger)
TCPSSLOptionssetSoLinger in class io.vertx.proton.ProtonClientOptionssoLinger - true if SO_linger is enabledpublic AmqpBridgeOptions setReusePort(boolean reusePort)
NetworkOptionssetReusePort in class io.vertx.proton.ProtonClientOptionsreusePort - the value of reuse portpublic AmqpBridgeOptions setTcpCork(boolean tcpCork)
TCPSSLOptionsTCP_CORK option - only with linux native transport.setTcpCork in class io.vertx.proton.ProtonClientOptionstcpCork - the cork valuepublic AmqpBridgeOptions setTcpFastOpen(boolean tcpFastOpen)
TCPSSLOptionsTCP_FASTOPEN option - only with linux native transport.setTcpFastOpen in class io.vertx.proton.ProtonClientOptionstcpFastOpen - the fast open valuepublic AmqpBridgeOptions setTcpQuickAck(boolean tcpQuickAck)
TCPSSLOptionsTCP_QUICKACK option - only with linux native transport.setTcpQuickAck in class io.vertx.proton.ProtonClientOptionstcpQuickAck - the quick ack valuepublic AmqpBridgeOptions setUsePooledBuffers(boolean usePooledBuffers)
TCPSSLOptionssetUsePooledBuffers in class io.vertx.proton.ProtonClientOptionsusePooledBuffers - true if pooled buffers enabledpublic AmqpBridgeOptions setIdleTimeout(int idleTimeout)
TCPSSLOptionsTCPSSLOptions.setIdleTimeoutUnit(TimeUnit)setIdleTimeout in class io.vertx.proton.ProtonClientOptionsidleTimeout - the timeout, in secondspublic AmqpBridgeOptions setIdleTimeoutUnit(TimeUnit idleTimeoutUnit)
TCPSSLOptionssetIdleTimeoutUnit in class io.vertx.proton.ProtonClientOptionsidleTimeoutUnit - specify time unit.public AmqpBridgeOptions setSsl(boolean ssl)
TCPSSLOptionssetSsl in class io.vertx.proton.ProtonClientOptionsssl - true if enabledpublic AmqpBridgeOptions setKeyStoreOptions(JksOptions options)
TCPSSLOptionssetKeyStoreOptions in class io.vertx.proton.ProtonClientOptionsoptions - the key store in jks formatpublic AmqpBridgeOptions setPfxKeyCertOptions(PfxOptions options)
TCPSSLOptionssetPfxKeyCertOptions in class io.vertx.proton.ProtonClientOptionsoptions - the key cert options in pfx formatpublic AmqpBridgeOptions setPemKeyCertOptions(PemKeyCertOptions options)
TCPSSLOptionssetPemKeyCertOptions in class io.vertx.proton.ProtonClientOptionsoptions - the options in pem formatpublic AmqpBridgeOptions setTrustStoreOptions(JksOptions options)
TCPSSLOptionssetTrustStoreOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust options in jks formatpublic AmqpBridgeOptions setPemTrustOptions(PemTrustOptions options)
TCPSSLOptionssetPemTrustOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust options in pem formatpublic AmqpBridgeOptions setPfxTrustOptions(PfxOptions options)
TCPSSLOptionssetPfxTrustOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust options in pfx formatpublic AmqpBridgeOptions addEnabledCipherSuite(String suite)
TCPSSLOptionsaddEnabledCipherSuite in class io.vertx.proton.ProtonClientOptionssuite - the suitepublic AmqpBridgeOptions addCrlPath(String crlPath) throws NullPointerException
TCPSSLOptionsaddCrlPath in class io.vertx.proton.ProtonClientOptionscrlPath - the pathNullPointerExceptionpublic AmqpBridgeOptions addCrlValue(Buffer crlValue) throws NullPointerException
TCPSSLOptionsaddCrlValue in class io.vertx.proton.ProtonClientOptionscrlValue - the valueNullPointerExceptionpublic AmqpBridgeOptions setTrustAll(boolean trustAll)
ClientOptionsBasesetTrustAll in class io.vertx.proton.ProtonClientOptionstrustAll - true if all should be trustedpublic AmqpBridgeOptions setConnectTimeout(int connectTimeout)
ClientOptionsBasesetConnectTimeout in class io.vertx.proton.ProtonClientOptionsconnectTimeout - connect timeout, in mspublic AmqpBridgeOptions setReconnectAttempts(int attempts)
NetClientOptionssetReconnectAttempts in class io.vertx.proton.ProtonClientOptionsattempts - the maximum number of reconnect attemptspublic AmqpBridgeOptions setReconnectInterval(long interval)
NetClientOptionssetReconnectInterval in class io.vertx.proton.ProtonClientOptionsinterval - the reconnect interval in mspublic AmqpBridgeOptions setUseAlpn(boolean useAlpn)
TCPSSLOptionssetUseAlpn in class io.vertx.proton.ProtonClientOptionsuseAlpn - true when Application-Layer Protocol Negotiation should be usedpublic AmqpBridgeOptions addEnabledSecureTransportProtocol(String protocol)
TCPSSLOptionsaddEnabledSecureTransportProtocol in class io.vertx.proton.ProtonClientOptionsprotocol - the SSL/TLS protocol to enablepublic AmqpBridgeOptions removeEnabledSecureTransportProtocol(String protocol)
TCPSSLOptionsremoveEnabledSecureTransportProtocol in class io.vertx.proton.ProtonClientOptionsprotocol - the SSL/TLS protocol to disablepublic AmqpBridgeOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols)
TCPSSLOptionssetEnabledSecureTransportProtocols in class io.vertx.proton.ProtonClientOptionsenabledSecureTransportProtocols - the SSL/TLS protocols to enablepublic AmqpBridgeOptions setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm)
NetClientOptionssetHostnameVerificationAlgorithm in class io.vertx.proton.ProtonClientOptionshostnameVerificationAlgorithm - should be HTTPS, LDAPS or an empty Stringpublic AmqpBridgeOptions setKeyCertOptions(KeyCertOptions options)
TCPSSLOptionssetKeyCertOptions in class io.vertx.proton.ProtonClientOptionsoptions - the key store optionspublic AmqpBridgeOptions setLogActivity(boolean logEnabled)
NetworkOptionssetLogActivity in class io.vertx.proton.ProtonClientOptionslogEnabled - true for logging the network activitypublic AmqpBridgeOptions setMetricsName(String metricsName)
ClientOptionsBasesetMetricsName in class io.vertx.proton.ProtonClientOptionsmetricsName - the metrics namepublic AmqpBridgeOptions setProxyOptions(ProxyOptions proxyOptions)
ClientOptionsBasesetProxyOptions in class io.vertx.proton.ProtonClientOptionsproxyOptions - proxy options objectpublic AmqpBridgeOptions setTrustOptions(TrustOptions options)
TCPSSLOptionssetTrustOptions in class io.vertx.proton.ProtonClientOptionsoptions - the trust optionspublic AmqpBridgeOptions setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions)
setJdkSslEngineOptions in class io.vertx.proton.ProtonClientOptionspublic AmqpBridgeOptions setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions)
setOpenSslEngineOptions in class io.vertx.proton.ProtonClientOptionspublic AmqpBridgeOptions setSslEngineOptions(SSLEngineOptions sslEngineOptions)
TCPSSLOptionssetSslEngineOptions in class io.vertx.proton.ProtonClientOptionssslEngineOptions - the ssl engine to usepublic AmqpBridgeOptions setLocalAddress(String localAddress)
ClientOptionsBasesetLocalAddress in class io.vertx.proton.ProtonClientOptionslocalAddress - the local addresspublic int hashCode()
hashCode in class io.vertx.proton.ProtonClientOptionspublic boolean equals(Object obj)
equals in class io.vertx.proton.ProtonClientOptionspublic AmqpBridgeOptions setVirtualHost(String virtualHost)
setVirtualHost in class io.vertx.proton.ProtonClientOptionspublic AmqpBridgeOptions setSniServerName(String sniServerName)
setSniServerName in class io.vertx.proton.ProtonClientOptionspublic AmqpBridgeOptions setMaxFrameSize(int maxFrameSize)
setMaxFrameSize in class io.vertx.proton.ProtonClientOptionsCopyright © 2021 Eclipse. All rights reserved.