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 TypeMethodDescriptionAmqpReceiver.closeAndForget()Closes the receiver.AmqpConnection.createDynamicReceiverAndAwait()Creates a dynamic receiver.AmqpClient.createReceiverAndAwait(String address) Creates a receiver used to consume messages from the given address.AmqpClient.createReceiverAndAwait(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.AmqpConnection.createReceiverAndAwait(String address) Creates a receiver used to consume messages from the given address.AmqpConnection.createReceiverAndAwait(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.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 delegate) Creates a new instance of theAmqpReceiver.AmqpReceiver.pause()AmqpReceiver.pipeToAndForget(WriteStream<AmqpMessage> dst) Pipe thisReadStreamto theWriteStream.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.