Package | Description |
---|---|
io.vertx.amqp | |
io.vertx.reactivex.amqp | |
io.vertx.rxjava.amqp |
Modifier and Type | Method and Description |
---|---|
AmqpClientOptions |
AmqpClientOptions.addCrlPath(String crlPath) |
AmqpClientOptions |
AmqpClientOptions.addCrlValue(Buffer crlValue) |
AmqpClientOptions |
AmqpClientOptions.addEnabledCipherSuite(String suite) |
AmqpClientOptions |
AmqpClientOptions.addEnabledSaslMechanism(String saslMechanism) |
AmqpClientOptions |
AmqpClientOptions.addEnabledSecureTransportProtocol(String protocol) |
AmqpClientOptions |
AmqpClientOptions.removeEnabledSecureTransportProtocol(String protocol) |
AmqpClientOptions |
AmqpClientOptions.setConnectionHostname(String hostname)
Explicitly override the hostname value used for the AMQP Open frame.
|
AmqpClientOptions |
AmqpClientOptions.setConnectTimeout(int connectTimeout) |
AmqpClientOptions |
AmqpClientOptions.setContainerId(String containerId)
Sets the container id.
|
AmqpClientOptions |
AmqpClientOptions.setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols) |
AmqpClientOptions |
AmqpClientOptions.setHeartbeat(int heartbeat) |
AmqpClientOptions |
AmqpClientOptions.setHost(String host)
Sets the host.
|
AmqpClientOptions |
AmqpClientOptions.setHostnameVerificationAlgorithm(String hostnameVerificationAlgorithm) |
AmqpClientOptions |
AmqpClientOptions.setIdleTimeout(int idleTimeout) |
AmqpClientOptions |
AmqpClientOptions.setJdkSslEngineOptions(JdkSSLEngineOptions sslEngineOptions) |
AmqpClientOptions |
AmqpClientOptions.setKeyStoreOptions(JksOptions options) |
AmqpClientOptions |
AmqpClientOptions.setLocalAddress(String localAddress) |
AmqpClientOptions |
AmqpClientOptions.setMaxFrameSize(int maxFrameSize) |
AmqpClientOptions |
AmqpClientOptions.setOpenSslEngineOptions(OpenSSLEngineOptions sslEngineOptions) |
AmqpClientOptions |
AmqpClientOptions.setPassword(String pwd)
Sets the password.
|
AmqpClientOptions |
AmqpClientOptions.setPemKeyCertOptions(PemKeyCertOptions options) |
AmqpClientOptions |
AmqpClientOptions.setPemTrustOptions(PemTrustOptions options) |
AmqpClientOptions |
AmqpClientOptions.setPfxKeyCertOptions(PfxOptions options) |
AmqpClientOptions |
AmqpClientOptions.setPfxTrustOptions(PfxOptions options) |
AmqpClientOptions |
AmqpClientOptions.setPort(int port)
Sets the port.
|
AmqpClientOptions |
AmqpClientOptions.setReceiveBufferSize(int receiveBufferSize) |
AmqpClientOptions |
AmqpClientOptions.setReconnectAttempts(int attempts) |
AmqpClientOptions |
AmqpClientOptions.setReconnectInterval(long interval) |
AmqpClientOptions |
AmqpClientOptions.setReuseAddress(boolean reuseAddress) |
AmqpClientOptions |
AmqpClientOptions.setReusePort(boolean reusePort) |
AmqpClientOptions |
AmqpClientOptions.setSendBufferSize(int sendBufferSize) |
AmqpClientOptions |
AmqpClientOptions.setSniServerName(String sniServerName) |
AmqpClientOptions |
AmqpClientOptions.setSoLinger(int soLinger) |
AmqpClientOptions |
AmqpClientOptions.setSsl(boolean ssl) |
AmqpClientOptions |
AmqpClientOptions.setSslEngineOptions(SSLEngineOptions sslEngineOptions) |
AmqpClientOptions |
AmqpClientOptions.setTcpCork(boolean tcpCork) |
AmqpClientOptions |
AmqpClientOptions.setTcpFastOpen(boolean tcpFastOpen) |
AmqpClientOptions |
AmqpClientOptions.setTcpKeepAlive(boolean tcpKeepAlive) |
AmqpClientOptions |
AmqpClientOptions.setTcpNoDelay(boolean tcpNoDelay) |
AmqpClientOptions |
AmqpClientOptions.setTcpQuickAck(boolean tcpQuickAck) |
AmqpClientOptions |
AmqpClientOptions.setTrafficClass(int trafficClass) |
AmqpClientOptions |
AmqpClientOptions.setTrustAll(boolean trustAll) |
AmqpClientOptions |
AmqpClientOptions.setTrustStoreOptions(JksOptions options) |
AmqpClientOptions |
AmqpClientOptions.setUsePooledBuffers(boolean usePooledBuffers) |
AmqpClientOptions |
AmqpClientOptions.setUsername(String username)
Sets the username.
|
AmqpClientOptions |
AmqpClientOptions.setVirtualHost(String virtualHost) |
Modifier and Type | Method and Description |
---|---|
static AmqpClient |
AmqpClient.create(AmqpClientOptions options)
Creates a new instance of
AmqpClient using an internal Vert.x instance (with default configuration) and
the given AMQP client configuration. |
static AmqpClient |
AmqpClient.create(Vertx vertx,
AmqpClientOptions options)
Creates a new instance of
AmqpClient with the given Vert.x instance and the given options. |
static void |
AmqpClientOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
AmqpClientOptions obj) |
static void |
AmqpClientOptionsConverter.toJson(AmqpClientOptions obj,
JsonObject json) |
static void |
AmqpClientOptionsConverter.toJson(AmqpClientOptions obj,
Map<String,Object> json) |
Constructor and Description |
---|
AmqpClientOptions(AmqpClientOptions other) |
Modifier and Type | Method and Description |
---|---|
static AmqpClient |
AmqpClient.create(AmqpClientOptions options)
Creates a new instance of
AmqpClient using an internal Vert.x instance (with default configuration) and
the given AMQP client configuration. |
static AmqpClient |
AmqpClient.create(Vertx vertx,
AmqpClientOptions options)
Creates a new instance of
AmqpClient with the given Vert.x instance and the given options. |
Modifier and Type | Method and Description |
---|---|
static AmqpClient |
AmqpClient.create(AmqpClientOptions options)
Creates a new instance of
AmqpClient using an internal Vert.x instance (with default configuration) and
the given AMQP client configuration. |
static AmqpClient |
AmqpClient.create(Vertx vertx,
AmqpClientOptions options)
Creates a new instance of
AmqpClient with the given Vert.x instance and the given options. |
Copyright © 2023 Eclipse. All rights reserved.