Uses of Class
io.vertx.mutiny.rabbitmq.RabbitMQMessage
Packages that use RabbitMQMessage
-
Uses of RabbitMQMessage in io.vertx.mutiny.rabbitmq
Fields in io.vertx.mutiny.rabbitmq with type parameters of type RabbitMQMessageModifier and TypeFieldDescriptionstatic final TypeArg<RabbitMQMessage>RabbitMQMessage.__TYPE_ARGMethods in io.vertx.mutiny.rabbitmq that return RabbitMQMessageModifier and TypeMethodDescriptionRabbitMQClient.basicGetAndAwait(String queue, boolean autoAck) Retrieve a message from a queue using AMQP.Basic.Getstatic RabbitMQMessageRabbitMQMessage.newInstance(io.vertx.rabbitmq.RabbitMQMessage delegate) Creates a new instance of theRabbitMQMessage.Methods in io.vertx.mutiny.rabbitmq that return types with arguments of type RabbitMQMessageModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<RabbitMQMessage>Retrieve a message from a queue using AMQP.Basic.GetRabbitMQConsumer.pipe()Pause this stream and return aPipeto transfer the elements of this stream to a destinationWriteStream.RabbitMQConsumer.toBlockingIterable()RabbitMQConsumer.toBlockingStream()io.smallrye.mutiny.Multi<RabbitMQMessage>RabbitMQConsumer.toMulti()Method parameters in io.vertx.mutiny.rabbitmq with type arguments of type RabbitMQMessageModifier and TypeMethodDescriptionRabbitMQConsumer.handler(Consumer<RabbitMQMessage> messageArrived) Set a message handler.io.smallrye.mutiny.Uni<Void>RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst) Pipe thisReadStreamto theWriteStream.voidRabbitMQConsumer.pipeToAndAwait(WriteStream<RabbitMQMessage> dst) Pipe thisReadStreamto theWriteStream.RabbitMQConsumer.pipeToAndForget(WriteStream<RabbitMQMessage> dst) Pipe thisReadStreamto theWriteStream.