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.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.
|
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 © 2023 Eclipse. All rights reserved.