| Package | Description | 
|---|---|
| io.vertx.rabbitmq | |
| io.vertx.reactivex.rabbitmq | |
| io.vertx.rxjava.rabbitmq | 
| Modifier and Type | Method and Description | 
|---|---|
RabbitMQOptions | 
RabbitMQOptions.setAddresses(List<com.rabbitmq.client.Address> addresses)
Set multiple addresses for cluster mode. 
 | 
RabbitMQOptions | 
RabbitMQOptions.setAutomaticRecoveryEnabled(boolean automaticRecoveryEnabled)
Enables or disables automatic connection recovery. 
 | 
RabbitMQOptions | 
RabbitMQOptions.setConnectionTimeout(int connectionTimeout)
Set the TCP connection timeout, in milliseconds,  
zero for infinite). | 
RabbitMQOptions | 
RabbitMQOptions.setHandshakeTimeout(int handshakeTimeout)
Set the AMQP 0-9-1 protocol handshake timeout, in milliseconds 
 | 
RabbitMQOptions | 
RabbitMQOptions.setHost(String host)
Set the default host to use for connections. 
 | 
RabbitMQOptions | 
RabbitMQOptions.setIncludeProperties(boolean includeProperties)
Set wether to include properties when a broker message is passed on the event bus 
 | 
RabbitMQOptions | 
RabbitMQOptions.setKeyCertOptions(KeyCertOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setKeyStoreOptions(JksOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setNetworkRecoveryInterval(long networkRecoveryInterval)
Set how long in milliseconds will automatic recovery wait before attempting to reconnect, default is  
5000 | 
RabbitMQOptions | 
RabbitMQOptions.setPassword(String password)
Set the password to use when connecting to the broker. 
 | 
RabbitMQOptions | 
RabbitMQOptions.setPemKeyCertOptions(PemKeyCertOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setPemTrustOptions(PemTrustOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setPfxKeyCertOptions(PfxOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setPfxTrustOptions(PfxOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setPort(int port)
Set the default port to use for connections. 
 | 
RabbitMQOptions | 
RabbitMQOptions.setReconnectAttempts(int attempts)  | 
RabbitMQOptions | 
RabbitMQOptions.setReconnectInterval(long interval)  | 
RabbitMQOptions | 
RabbitMQOptions.setRequestedChannelMax(int requestedChannelMax)
Set the initially requested maximum channel number,  
zero for unlimited. | 
RabbitMQOptions | 
RabbitMQOptions.setRequestedHeartbeat(int requestedHeartbeat)
Set the initially requested heartbeat interval, in seconds,  
zero for none. | 
RabbitMQOptions | 
RabbitMQOptions.setSsl(boolean ssl)  | 
RabbitMQOptions | 
RabbitMQOptions.setTrustAll(boolean trustAll)  | 
RabbitMQOptions | 
RabbitMQOptions.setTrustOptions(TrustOptions options)  | 
RabbitMQOptions | 
RabbitMQOptions.setUri(String uri)  | 
RabbitMQOptions | 
RabbitMQOptions.setUser(String user)
Set the AMQP user name to use when connecting to the broker. 
 | 
RabbitMQOptions | 
RabbitMQOptions.setVirtualHost(String virtualHost)
Set the virtual host to use when connecting to the broker. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static RabbitMQClient | 
RabbitMQClient.create(Vertx vertx,
      RabbitMQOptions config)
Create and return a client. 
 | 
static void | 
RabbitMQOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        RabbitMQOptions obj)  | 
static void | 
RabbitMQOptionsConverter.toJson(RabbitMQOptions obj,
      JsonObject json)  | 
static void | 
RabbitMQOptionsConverter.toJson(RabbitMQOptions obj,
      Map<String,Object> json)  | 
| Constructor and Description | 
|---|
RabbitMQOptions(RabbitMQOptions other)  | 
| Modifier and Type | Method and Description | 
|---|---|
static RabbitMQClient | 
RabbitMQClient.create(Vertx vertx,
      RabbitMQOptions config)
Create and return a client. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static RabbitMQClient | 
RabbitMQClient.create(Vertx vertx,
      RabbitMQOptions config)
Create and return a client. 
 | 
Copyright © 2020 Eclipse. All rights reserved.