| Package | Description |
|---|---|
| io.vertx.rabbitmq | |
| io.vertx.reactivex.rabbitmq | |
| io.vertx.rxjava.rabbitmq | |
| io.vertx.rxjava3.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 |
|---|---|
Future<RabbitMQConsumer> |
RabbitMQClient.basicConsumer(String queue,
QueueOptions options)
Like
RabbitMQClient.basicConsumer(String, QueueOptions, Handler) but returns a Future of the asynchronous result |
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)
Create a consumer with the given
options. |
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)
Create a consumer with the given
options. |
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 |
|---|---|
Single<RabbitMQConsumer> |
RabbitMQClient.basicConsumer(String queue,
QueueOptions options)
Create a consumer with the given
options. |
Single<RabbitMQConsumer> |
RabbitMQClient.rxBasicConsumer(String queue,
QueueOptions options)
Create a consumer with the given
options. |
Copyright © 2021 Eclipse. All rights reserved.