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