| Package | Description |
|---|---|
| io.vertx.rabbitmq | |
| io.vertx.reactivex.rabbitmq | |
| io.vertx.rxjava.rabbitmq |
| Modifier and Type | Method and Description |
|---|---|
Future<RabbitMQMessage> |
RabbitMQClient.basicGet(String queue,
boolean autoAck)
Like
RabbitMQClient.basicGet(String, boolean, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
void |
RabbitMQClient.basicGet(String queue,
boolean autoAck,
Handler<AsyncResult<RabbitMQMessage>> resultHandler)
Retrieve a message from a queue using AMQP.Basic.Get
|
RabbitMQConsumer |
RabbitMQConsumer.handler(Handler<RabbitMQMessage> messageArrived)
Set a message handler.
|
| Modifier and Type | Method and Description |
|---|---|
RabbitMQMessage |
RabbitMQMessage.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static RabbitMQMessage |
RabbitMQMessage.newInstance(RabbitMQMessage arg) |
| Constructor and Description |
|---|
RabbitMQMessage(RabbitMQMessage delegate) |
| Modifier and Type | Method and Description |
|---|---|
RabbitMQMessage |
RabbitMQMessage.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static RabbitMQMessage |
RabbitMQMessage.newInstance(RabbitMQMessage arg) |
| Constructor and Description |
|---|
RabbitMQMessage(RabbitMQMessage delegate) |
Copyright © 2021 Eclipse. All rights reserved.