| Package | Description | 
|---|---|
| io.vertx.rabbitmq | |
| io.vertx.reactivex.rabbitmq | |
| io.vertx.rxjava.rabbitmq | 
| Modifier and Type | Method and Description | 
|---|---|
QueueOptions | 
QueueOptions.setAutoAck(boolean autoAck)  | 
QueueOptions | 
QueueOptions.setKeepMostRecent(boolean keepMostRecent)  | 
QueueOptions | 
QueueOptions.setMaxInternalQueueSize(int maxInternalQueueSize)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RabbitMQClient.basicConsumer(String queue,
             QueueOptions options,
             Handler<AsyncResult<RabbitMQConsumer>> resultHandler)
Create a consumer with the given  
options. | 
static void | 
QueueOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        QueueOptions obj)  | 
static void | 
QueueOptionsConverter.toJson(QueueOptions obj,
      JsonObject json)  | 
static void | 
QueueOptionsConverter.toJson(QueueOptions obj,
      Map<String,Object> json)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RabbitMQClient.basicConsumer(String queue,
             QueueOptions options,
             Handler<AsyncResult<RabbitMQConsumer>> resultHandler)
Create a consumer with the given  
options. | 
Single<RabbitMQConsumer> | 
RabbitMQClient.rxBasicConsumer(String queue,
               QueueOptions options)
Create a consumer with the given  
options. | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RabbitMQClient.basicConsumer(String queue,
             QueueOptions options,
             Handler<AsyncResult<RabbitMQConsumer>> resultHandler)
Create a consumer with the given  
options. | 
Observable<RabbitMQConsumer> | 
RabbitMQClient.basicConsumerObservable(String queue,
                       QueueOptions options)
Deprecated. 
 
use  
RabbitMQClient.rxBasicConsumer(java.lang.String) instead | 
Single<RabbitMQConsumer> | 
RabbitMQClient.rxBasicConsumer(String queue,
               QueueOptions options)
Create a consumer with the given  
options. | 
Copyright © 2020 Eclipse. All rights reserved.