Uses of Class
io.vertx.mutiny.amqp.AmqpMessage

Packages that use AmqpMessage

Package	Description
io.vertx.mutiny.amqp

Uses of AmqpMessage in io.vertx.mutiny.amqp

Fields in io.vertx.mutiny.amqp with type parameters of type AmqpMessage

Modifier and Type	Field	Description
static final TypeArg<AmqpMessage>	AmqpMessage.__TYPE_ARG

Methods in io.vertx.mutiny.amqp that return AmqpMessage

Modifier and Type	Method	Description
AmqpMessage	AmqpMessage.accepted()
AmqpMessage	AmqpMessageBuilder.build()
AmqpMessage	AmqpMessage.modified(boolean deliveryFailed, boolean undeliverableHere)
static AmqpMessage	AmqpMessage.newInstance(io.vertx.amqp.AmqpMessage arg)
AmqpMessage	AmqpMessage.rejected()
AmqpMessage	AmqpMessage.released()

Methods in io.vertx.mutiny.amqp that return types with arguments of type AmqpMessage

Modifier and Type	Method	Description
WriteStream<AmqpMessage>	AmqpSender.drainHandler(Runnable arg0)
Pipe<AmqpMessage>	AmqpReceiver.pipe()
Iterable<AmqpMessage>	AmqpReceiver.toBlockingIterable()
Stream<AmqpMessage>	AmqpReceiver.toBlockingStream()
io.smallrye.mutiny.Multi<AmqpMessage>	AmqpReceiver.toMulti()
WriteStreamSubscriber<AmqpMessage>	AmqpSender.toSubscriber()

Methods in io.vertx.mutiny.amqp with parameters of type AmqpMessage

Modifier and Type	Method	Description
static AmqpMessageBuilder	AmqpMessage.create(AmqpMessage existing)
io.smallrye.mutiny.Uni<Void>	AmqpSender.end(AmqpMessage data)
Void	AmqpSender.endAndAwait(AmqpMessage data)
void	AmqpSender.endAndForget(AmqpMessage data)
AmqpSender	AmqpSender.send(AmqpMessage message)
io.smallrye.mutiny.Uni<Void>	AmqpSender.sendWithAck(AmqpMessage message)	Sends an AMQP message and waits for an acknowledgement.
Void	AmqpSender.sendWithAckAndAwait(AmqpMessage message)	Blocking variant of AmqpSender.sendWithAck(io.vertx.mutiny.amqp.AmqpMessage).
AmqpSender	AmqpSender.sendWithAckAndForget(AmqpMessage message)	Variant of AmqpSender.sendWithAck(io.vertx.mutiny.amqp.AmqpMessage) that ignores the result of the operation.
io.smallrye.mutiny.Uni<Void>	AmqpSender.write(AmqpMessage arg0)
Void	AmqpSender.writeAndAwait(AmqpMessage arg0)
void	AmqpSender.writeAndForget(AmqpMessage arg0)

Method parameters in io.vertx.mutiny.amqp with type arguments of type AmqpMessage

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