Package | Description |
---|---|
io.vertx.proton |
= Vert.x Proton
This component facilitates AMQP integrations for Vert.x by providing a thin wrapper around the
link:http://qpid.apache.org/[Apache Qpid] Proton AMQP 1.0 protocol engine.
|
Modifier and Type | Method and Description |
---|---|
ProtonClientOptions |
ProtonClientOptions.addCrlPath(String crlPath) |
ProtonClientOptions |
ProtonClientOptions.addCrlValue(io.vertx.core.buffer.Buffer crlValue) |
ProtonClientOptions |
ProtonClientOptions.addEnabledCipherSuite(String suite) |
ProtonClientOptions |
ProtonClientOptions.addEnabledSaslMechanism(String saslMechanism)
Adds a mechanism name that the client may use during SASL negotiation.
|
ProtonClientOptions |
ProtonClientOptions.addEnabledSecureTransportProtocol(String protocol) |
ProtonClientOptions |
ProtonClientOptions.removeEnabledSecureTransportProtocol(String protocol) |
ProtonClientOptions |
ProtonClientOptions.setConnectTimeout(int connectTimeout) |
ProtonClientOptions |
ProtonClientOptions.setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols) |
ProtonClientOptions |
ProtonClientOptions.setHeartbeat(int heartbeat)
Set the heartbeat (in milliseconds) as maximum delay between sending frames for the remote peers.
|
ProtonClientOptions |
ProtonClientOptions.setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm) |
ProtonClientOptions |
ProtonClientOptions.setIdleTimeout(int idleTimeout) |
ProtonClientOptions |
ProtonClientOptions.setJdkSslEngineOptions(io.vertx.core.net.JdkSSLEngineOptions sslEngineOptions) |
ProtonClientOptions |
ProtonClientOptions.setKeyCertOptions(io.vertx.core.net.KeyCertOptions options) |
ProtonClientOptions |
ProtonClientOptions.setKeyStoreOptions(io.vertx.core.net.JksOptions options) |
ProtonClientOptions |
ProtonClientOptions.setLocalAddress(String localAddress) |
ProtonClientOptions |
ProtonClientOptions.setLogActivity(boolean logEnabled) |
ProtonClientOptions |
ProtonClientOptions.setMaxFrameSize(int maxFrameSize)
Sets the maximum frame size to announce in the AMQP OPEN frame.
|
ProtonClientOptions |
ProtonClientOptions.setMetricsName(String metricsName) |
ProtonClientOptions |
ProtonClientOptions.setOpenSslEngineOptions(io.vertx.core.net.OpenSSLEngineOptions sslEngineOptions) |
ProtonClientOptions |
ProtonClientOptions.setPemKeyCertOptions(io.vertx.core.net.PemKeyCertOptions options) |
ProtonClientOptions |
ProtonClientOptions.setPemTrustOptions(io.vertx.core.net.PemTrustOptions options) |
ProtonClientOptions |
ProtonClientOptions.setPfxKeyCertOptions(io.vertx.core.net.PfxOptions options) |
ProtonClientOptions |
ProtonClientOptions.setPfxTrustOptions(io.vertx.core.net.PfxOptions options) |
ProtonClientOptions |
ProtonClientOptions.setProxyOptions(io.vertx.core.net.ProxyOptions proxyOptions) |
ProtonClientOptions |
ProtonClientOptions.setReceiveBufferSize(int receiveBufferSize) |
ProtonClientOptions |
ProtonClientOptions.setReconnectAttempts(int attempts) |
ProtonClientOptions |
ProtonClientOptions.setReconnectInterval(long interval) |
ProtonClientOptions |
ProtonClientOptions.setReuseAddress(boolean reuseAddress) |
ProtonClientOptions |
ProtonClientOptions.setReusePort(boolean reusePort) |
ProtonClientOptions |
ProtonClientOptions.setSendBufferSize(int sendBufferSize) |
ProtonClientOptions |
ProtonClientOptions.setSniServerName(String sniServerName)
Explicitly override the hostname to use for the TLS SNI server name.
|
ProtonClientOptions |
ProtonClientOptions.setSoLinger(int soLinger) |
ProtonClientOptions |
ProtonClientOptions.setSsl(boolean ssl) |
ProtonClientOptions |
ProtonClientOptions.setSslEngineOptions(io.vertx.core.net.SSLEngineOptions sslEngineOptions) |
ProtonClientOptions |
ProtonClientOptions.setTcpCork(boolean tcpCork) |
ProtonClientOptions |
ProtonClientOptions.setTcpFastOpen(boolean tcpFastOpen) |
ProtonClientOptions |
ProtonClientOptions.setTcpKeepAlive(boolean tcpKeepAlive) |
ProtonClientOptions |
ProtonClientOptions.setTcpNoDelay(boolean tcpNoDelay) |
ProtonClientOptions |
ProtonClientOptions.setTcpQuickAck(boolean tcpQuickAck) |
ProtonClientOptions |
ProtonClientOptions.setTrafficClass(int trafficClass) |
ProtonClientOptions |
ProtonClientOptions.setTrustAll(boolean trustAll) |
ProtonClientOptions |
ProtonClientOptions.setTrustOptions(io.vertx.core.net.TrustOptions options) |
ProtonClientOptions |
ProtonClientOptions.setTrustStoreOptions(io.vertx.core.net.JksOptions options) |
ProtonClientOptions |
ProtonClientOptions.setUseAlpn(boolean useAlpn) |
ProtonClientOptions |
ProtonClientOptions.setUsePooledBuffers(boolean usePooledBuffers) |
ProtonClientOptions |
ProtonClientOptions.setVirtualHost(String virtualHost)
Override the hostname value used in the connection AMQP Open frame and TLS SNI server name (if TLS is in use).
|
Modifier and Type | Method and Description |
---|---|
void |
ProtonClient.connect(ProtonClientOptions options,
String host,
int port,
io.vertx.core.Handler<io.vertx.core.AsyncResult<ProtonConnection>> connectionHandler)
Connect to the given host and port, without credentials.
|
void |
ProtonClient.connect(ProtonClientOptions options,
String host,
int port,
String username,
String password,
io.vertx.core.Handler<io.vertx.core.AsyncResult<ProtonConnection>> connectionHandler)
Connect to the given host and port, with credentials (if required by server peer).
|
Constructor and Description |
---|
ProtonClientOptions(ProtonClientOptions other)
Copy constructor
|
Copyright © 2018 Eclipse. All rights reserved.