Package | Description |
---|---|
io.vertx.rabbitmq | |
io.vertx.reactivex.rabbitmq | |
io.vertx.rxjava.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) |
Copyright © 2021 Eclipse. All rights reserved.