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.