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