Package | Description |
---|---|
io.vertx.rxjava.rabbitmq |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<RabbitMQConsumer> |
RabbitMQConsumer.__TYPE_ARG |
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.
|
static RabbitMQConsumer |
RabbitMQConsumer.newInstance(RabbitMQConsumer arg) |
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 |
---|---|
Observable<RabbitMQConsumer> |
RabbitMQClient.basicConsumerObservable(String queue)
Deprecated.
use
RabbitMQClient.rxBasicConsumer(java.lang.String) instead |
Observable<RabbitMQConsumer> |
RabbitMQClient.basicConsumerObservable(String queue,
QueueOptions options)
Deprecated.
use
RabbitMQClient.rxBasicConsumer(java.lang.String) instead |
Single<RabbitMQConsumer> |
RabbitMQClient.rxBasicConsumer(String queue) |
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,
Handler<AsyncResult<RabbitMQConsumer>> resultHandler) |
void |
RabbitMQClient.basicConsumer(String queue,
QueueOptions options,
Handler<AsyncResult<RabbitMQConsumer>> resultHandler)
Create a consumer with the given
options . |
Copyright © 2023 Eclipse. All rights reserved.