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 AmqpReceiverAmqpReceiver.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.