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()	When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message.
AmqpMessage	AmqpMessageBuilder.build()
AmqpMessage	AmqpMessage.modified(boolean deliveryFailed, boolean undeliverableHere)	When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as modified.
static AmqpMessage	AmqpMessage.newInstance(io.vertx.amqp.AmqpMessage delegate)	Creates a new instance of the AmqpMessage.
AmqpMessage	AmqpMessage.rejected()	When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as rejected.
AmqpMessage	AmqpMessage.released()	When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as released.

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

Modifier and Type	Method	Description
Pipe<AmqpMessage>	AmqpReceiver.pipe()	Pause this stream and return a Pipe to transfer the elements of this stream to a destination WriteStream.
Iterable<AmqpMessage>	AmqpReceiver.toBlockingIterable()
Stream<AmqpMessage>	AmqpReceiver.toBlockingStream()
io.smallrye.mutiny.Multi<AmqpMessage>	AmqpReceiver.toMulti()
Flow.Subscriber<AmqpMessage>	AmqpSender.toSubscriber()	Converts the current write stream to a subscriber.

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

Modifier and Type	Method	Description
static AmqpMessageBuilder	AmqpMessage.create(AmqpMessage existing)	Creates a builder to create a new AmqpMessage copying the metadata from the passed message.
io.smallrye.mutiny.Uni<Void>	AmqpSender.end(AmqpMessage data)	Same as AmqpSender.end() but writes some data to the stream before ending.
void	AmqpSender.endAndAwait(AmqpMessage data)	Same as AmqpSender.end() but writes some data to the stream before ending.
AmqpSender	AmqpSender.endAndForget(AmqpMessage data)	Same as AmqpSender.end() but writes some data to the stream before ending.
AmqpSender	AmqpSender.send(AmqpMessage message)	Sends an AMQP message.
io.smallrye.mutiny.Uni<Void>	AmqpSender.sendWithAck(AmqpMessage message)	Sends an AMQP message and waits for an acknowledgement.
void	AmqpSender.sendWithAckAndAwait(AmqpMessage message)	Sends an AMQP message and waits for an acknowledgement.
AmqpSender	AmqpSender.sendWithAckAndForget(AmqpMessage message)	Sends an AMQP message and waits for an acknowledgement.
io.smallrye.mutiny.Uni<Void>	AmqpSender.write(AmqpMessage data)	Write some data to the stream.
void	AmqpSender.writeAndAwait(AmqpMessage data)	Write some data to the stream.
AmqpSender	AmqpSender.writeAndForget(AmqpMessage data)	Write some data to the stream.

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)	Pipe this ReadStream to the WriteStream.
void	AmqpReceiver.pipeToAndAwait(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.
AmqpReceiver	AmqpReceiver.pipeToAndForget(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.