| 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.