Uses of Interface
io.vertx.rabbitmq.RabbitMQConsumer
-
Packages that use RabbitMQConsumer Package Description io.vertx.rabbitmq io.vertx.reactivex.rabbitmq io.vertx.rxjava3.rabbitmq -
-
Uses of RabbitMQConsumer in io.vertx.rabbitmq
Methods in io.vertx.rabbitmq that return RabbitMQConsumer Modifier and Type Method Description RabbitMQConsumerRabbitMQConsumer. endHandler(Handler<Void> endHandler)Set an end handler.RabbitMQConsumerRabbitMQConsumer. exceptionHandler(Handler<Throwable> exceptionHandler)Set an exception handler on the read stream.RabbitMQConsumerRabbitMQConsumer. fetch(long amount)Fetch the specifiedamountof elements.RabbitMQConsumerRabbitMQConsumer. handler(Handler<RabbitMQMessage> messageArrived)Set a message handler.RabbitMQConsumerRabbitMQConsumer. pause()Pause the stream of incoming messages from queue.RabbitMQConsumerRabbitMQConsumer. resume()Resume reading from a queue.RabbitMQConsumerRabbitMQConsumer. setQueueName(String name)Set the name of the queue.Methods in io.vertx.rabbitmq that return types with arguments of type RabbitMQConsumer Modifier and Type Method Description default Future<RabbitMQConsumer>RabbitMQClient. basicConsumer(String queue)Future<RabbitMQConsumer>RabbitMQClient. basicConsumer(String queue, QueueOptions options)Create a consumer with the givenoptions. -
Uses of RabbitMQConsumer in io.vertx.reactivex.rabbitmq
Methods in io.vertx.reactivex.rabbitmq that return RabbitMQConsumer Modifier and Type Method Description RabbitMQConsumerRabbitMQConsumer. getDelegate()Methods in io.vertx.reactivex.rabbitmq with parameters of type RabbitMQConsumer Modifier and Type Method Description static RabbitMQConsumerRabbitMQConsumer. newInstance(RabbitMQConsumer arg)Constructors in io.vertx.reactivex.rabbitmq with parameters of type RabbitMQConsumer Constructor Description RabbitMQConsumer(RabbitMQConsumer delegate) -
Uses of RabbitMQConsumer in io.vertx.rxjava3.rabbitmq
Methods in io.vertx.rxjava3.rabbitmq that return RabbitMQConsumer Modifier and Type Method Description RabbitMQConsumerRabbitMQConsumer. getDelegate()Methods in io.vertx.rxjava3.rabbitmq with parameters of type RabbitMQConsumer Modifier and Type Method Description static RabbitMQConsumerRabbitMQConsumer. newInstance(RabbitMQConsumer arg)Constructors in io.vertx.rxjava3.rabbitmq with parameters of type RabbitMQConsumer Constructor Description RabbitMQConsumer(RabbitMQConsumer delegate)
-