| Package | Description | 
|---|---|
| io.vertx.rabbitmq | |
| io.vertx.reactivex.rabbitmq | |
| io.vertx.rxjava.rabbitmq | |
| io.vertx.rxjava3.rabbitmq | 
| Modifier and Type | Method and Description | 
|---|---|
RabbitMQConsumer | 
RabbitMQConsumer.endHandler(Handler<Void> endHandler)
Set an end handler. 
 | 
RabbitMQConsumer | 
RabbitMQConsumer.exceptionHandler(Handler<Throwable> exceptionHandler)
Set an exception handler on the read stream. 
 | 
RabbitMQConsumer | 
RabbitMQConsumer.fetch(long amount)
Fetch the specified  
amount of elements. | 
RabbitMQConsumer | 
RabbitMQConsumer.handler(Handler<RabbitMQMessage> messageArrived)
Set a message handler. 
 | 
RabbitMQConsumer | 
RabbitMQConsumer.pause()
Pause the stream of incoming messages from queue. 
 | 
RabbitMQConsumer | 
RabbitMQConsumer.resume()
Resume reading from a queue. 
 | 
RabbitMQConsumer | 
RabbitMQConsumer.setQueueName(String name)
Set the name of the queue. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default Future<RabbitMQConsumer> | 
RabbitMQClient.basicConsumer(String queue)
Like  
RabbitMQClient.basicConsumer(String, Handler) but returns a Future of the asynchronous result | 
Future<RabbitMQConsumer> | 
RabbitMQClient.basicConsumer(String queue,
             QueueOptions options)
Like  
RabbitMQClient.basicConsumer(String, QueueOptions, Handler) but returns a Future of the asynchronous result | 
| Modifier and Type | Method and Description | 
|---|---|
default void | 
RabbitMQClient.basicConsumer(String queue,
             Handler<AsyncResult<RabbitMQConsumer>> resultHandler)  | 
void | 
RabbitMQClient.basicConsumer(String queue,
             QueueOptions options,
             Handler<AsyncResult<RabbitMQConsumer>> resultHandler)
Create a consumer with the given  
options. | 
| Modifier and Type | Method and Description | 
|---|---|
RabbitMQConsumer | 
RabbitMQConsumer.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static RabbitMQConsumer | 
RabbitMQConsumer.newInstance(RabbitMQConsumer arg)  | 
| Constructor and Description | 
|---|
RabbitMQConsumer(RabbitMQConsumer delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
RabbitMQConsumer | 
RabbitMQConsumer.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static RabbitMQConsumer | 
RabbitMQConsumer.newInstance(RabbitMQConsumer arg)  | 
| Constructor and Description | 
|---|
RabbitMQConsumer(RabbitMQConsumer delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
RabbitMQConsumer | 
RabbitMQConsumer.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static RabbitMQConsumer | 
RabbitMQConsumer.newInstance(RabbitMQConsumer arg)  | 
| Constructor and Description | 
|---|
RabbitMQConsumer(RabbitMQConsumer delegate)  | 
Copyright © 2024 Eclipse. All rights reserved.