Uses of Class
io.vertx.mutiny.rabbitmq.RabbitMQMessage

Packages that use RabbitMQMessage

Package	Description
io.vertx.mutiny.rabbitmq

Uses of RabbitMQMessage in io.vertx.mutiny.rabbitmq

Fields in io.vertx.mutiny.rabbitmq with type parameters of type RabbitMQMessage

Modifier and Type	Field	Description
static TypeArg<RabbitMQMessage>	RabbitMQMessage.__TYPE_ARG

Methods in io.vertx.mutiny.rabbitmq that return RabbitMQMessage

Modifier and Type	Method	Description
RabbitMQMessage	RabbitMQClient.basicGetAndAwait(String queue, boolean autoAck)	Blocking variant of RabbitMQClient.basicGet(String,boolean).
static RabbitMQMessage	RabbitMQMessage.newInstance(io.vertx.rabbitmq.RabbitMQMessage arg)

Methods in io.vertx.mutiny.rabbitmq that return types with arguments of type RabbitMQMessage

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<RabbitMQMessage>	RabbitMQClient.basicGet(String queue, boolean autoAck)	Retrieve a message from a queue using AMQP.Basic.Get
Pipe<RabbitMQMessage>	RabbitMQConsumer.pipe()
Iterable<RabbitMQMessage>	RabbitMQConsumer.toBlockingIterable()
Stream<RabbitMQMessage>	RabbitMQConsumer.toBlockingStream()
io.smallrye.mutiny.Multi<RabbitMQMessage>	RabbitMQConsumer.toMulti()

Method parameters in io.vertx.mutiny.rabbitmq with type arguments of type RabbitMQMessage

Modifier and Type	Method	Description
RabbitMQConsumer	RabbitMQConsumer.handler(Consumer<RabbitMQMessage> messageArrived)
io.smallrye.mutiny.Uni<Void>	RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst)
Void	RabbitMQConsumer.pipeToAndAwait(WriteStream<RabbitMQMessage> dst)
void	RabbitMQConsumer.pipeToAndForget(WriteStream<RabbitMQMessage> dst)