Uses of Interface
io.vertx.amqp.AmqpMessage
Packages that use AmqpMessage
-
Uses of AmqpMessage in io.vertx.amqp
Subinterfaces with type arguments of type AmqpMessage in io.vertx.amqpModifier and TypeInterfaceDescriptioninterfaceInterface used to consume AMQP message as a stream of message.interfaceAMQP Sender interface used to send messages.Methods in io.vertx.amqp that return AmqpMessageModifier and TypeMethodDescriptionAmqpMessage.accepted()When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message.AmqpMessageBuilder.build()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 asmodified.AmqpMessage.rejected()When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message asrejected.AmqpMessage.released()When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message asreleased.Methods in io.vertx.amqp with parameters of type AmqpMessageModifier and TypeMethodDescriptionstatic AmqpMessageBuilderAmqpMessage.create(AmqpMessage existing) Creates a builder to create a newAmqpMessagecopying the metadata from the passed message.AmqpSender.send(AmqpMessage message) Sends an AMQP message.AmqpSender.sendWithAck(AmqpMessage message) Sends an AMQP message and waits for an acknowledgement.Method parameters in io.vertx.amqp with type arguments of type AmqpMessage -
Uses of AmqpMessage in io.vertx.reactivex.amqp
Methods in io.vertx.reactivex.amqp that return AmqpMessageMethods in io.vertx.reactivex.amqp with parameters of type AmqpMessageConstructors in io.vertx.reactivex.amqp with parameters of type AmqpMessage -
Uses of AmqpMessage in io.vertx.rxjava3.amqp
Methods in io.vertx.rxjava3.amqp that return AmqpMessageMethods in io.vertx.rxjava3.amqp with parameters of type AmqpMessageConstructors in io.vertx.rxjava3.amqp with parameters of type AmqpMessage