Uses of Class
io.vertx.mutiny.amqp.AmqpReceiver
Packages that use AmqpReceiver
-
Uses of AmqpReceiver in io.vertx.mutiny.amqp
Fields in io.vertx.mutiny.amqp with type parameters of type AmqpReceiverMethods in io.vertx.mutiny.amqp that return AmqpReceiverModifier and TypeMethodDescriptionAmqpConnection.createDynamicReceiverAndAwait()
Blocking variant ofAmqpConnection.createDynamicReceiver()
.AmqpClient.createReceiverAndAwait
(String address) Blocking variant ofAmqpClient.createReceiver(String)
.AmqpClient.createReceiverAndAwait
(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions) Blocking variant ofAmqpClient.createReceiver(String,AmqpReceiverOptions)
.AmqpConnection.createReceiverAndAwait
(String address) Blocking variant ofAmqpConnection.createReceiver(String)
.AmqpConnection.createReceiverAndAwait
(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions) Blocking variant ofAmqpConnection.createReceiver(String,AmqpReceiverOptions)
.AmqpReceiver.endHandler
(Runnable endHandler) AmqpReceiver.exceptionHandler
(Consumer<Throwable> handler) AmqpReceiver.fetch
(long amount) AmqpReceiver.handler
(Consumer<AmqpMessage> handler) static AmqpReceiver
AmqpReceiver.newInstance
(io.vertx.amqp.AmqpReceiver arg) AmqpReceiver.pause()
AmqpReceiver.resume()
Methods in io.vertx.mutiny.amqp that return types with arguments of type AmqpReceiverModifier and TypeMethodDescriptionio.smallrye.mutiny.Uni<AmqpReceiver>
AmqpConnection.createDynamicReceiver()
Creates a dynamic receiver.io.smallrye.mutiny.Uni<AmqpReceiver>
AmqpClient.createReceiver
(String address) Creates a receiver used to consume messages from the given address.io.smallrye.mutiny.Uni<AmqpReceiver>
AmqpClient.createReceiver
(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.io.smallrye.mutiny.Uni<AmqpReceiver>
AmqpConnection.createReceiver
(String address) Creates a receiver used to consume messages from the given address.io.smallrye.mutiny.Uni<AmqpReceiver>
AmqpConnection.createReceiver
(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.