Uses of Class
io.vertx.mutiny.rabbitmq.RabbitMQClient

Packages that use RabbitMQClient

Package	Description
io.vertx.mutiny.rabbitmq

Uses of RabbitMQClient in io.vertx.mutiny.rabbitmq

Fields in io.vertx.mutiny.rabbitmq with type parameters of type RabbitMQClient

Modifier and Type	Field	Description
static final TypeArg<RabbitMQClient>	RabbitMQClient.__TYPE_ARG

Methods in io.vertx.mutiny.rabbitmq that return RabbitMQClient

Modifier and Type	Method	Description
RabbitMQClient	RabbitMQClient.addConfirmListenerAndForget(int maxQueueSize)	Add a Confirm Listener to the channel.
RabbitMQClient	RabbitMQClient.basicAckAndForget(long deliveryTag, boolean multiple)	Acknowledge one or several received messages.
RabbitMQClient	RabbitMQClient.basicConsumerAndForget(String queue)	Unlike the bare Vert.x variant, this method ignores the RabbitMQConsumer result or any failure.
RabbitMQClient	RabbitMQClient.basicConsumerAndForget(String queue, io.vertx.rabbitmq.QueueOptions options)	Create a consumer with the given options.
RabbitMQClient	RabbitMQClient.basicGetAndForget(String queue, boolean autoAck)	Retrieve a message from a queue using AMQP.Basic.Get
RabbitMQClient	RabbitMQClient.basicNackAndForget(long deliveryTag, boolean multiple, boolean requeue)	Reject one or several received messages.
RabbitMQClient	RabbitMQClient.basicPublishAndForget(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, io.vertx.core.buffer.Buffer body)	Publish a message.
RabbitMQClient	RabbitMQClient.basicPublishAndForget(String exchange, String routingKey, io.vertx.core.buffer.Buffer body)	Publish a message.
RabbitMQClient	RabbitMQClient.basicPublishWithDeliveryTagAndForget(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, io.vertx.core.buffer.Buffer body, Consumer<Long> deliveryTagHandler)	Publish a message.
RabbitMQClient	RabbitMQClient.basicQosAndForget(int prefetchCount)	Request a specific prefetchCount "quality of service" settings for this channel.
RabbitMQClient	RabbitMQClient.basicQosAndForget(int prefetchCount, boolean global)	Request a specific prefetchCount "quality of service" settings for this channel.
RabbitMQClient	RabbitMQClient.basicQosAndForget(int prefetchSize, int prefetchCount, boolean global)	Request specific "quality of service" settings.
RabbitMQClient	RabbitMQClient.confirmSelectAndForget()	Enables publisher acknowledgements on this channel.
static RabbitMQClient	RabbitMQClient.create(Vertx vertx)	Create and return a client configured with the default options.
static RabbitMQClient	RabbitMQClient.create(Vertx vertx, io.vertx.rabbitmq.RabbitMQOptions config)	Create and return a client.
RabbitMQClient	RabbitMQClient.exchangeBindAndForget(String destination, String source, String routingKey)	Bind an exchange to an exchange.
RabbitMQClient	RabbitMQClient.exchangeBindAndForget(String destination, String source, String routingKey, Map<String,Object> arguments)	Bind an exchange to an exchange.
RabbitMQClient	RabbitMQClient.exchangeDeclareAndForget(String exchange, String type, boolean durable, boolean autoDelete)	Declare an exchange.
RabbitMQClient	RabbitMQClient.exchangeDeclareAndForget(String exchange, String type, boolean durable, boolean autoDelete, io.vertx.core.json.JsonObject config)	Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
RabbitMQClient	RabbitMQClient.exchangeDeleteAndForget(String exchange)	Delete an exchange, without regard for whether it is in use or not.
RabbitMQClient	RabbitMQClient.exchangeUnbindAndForget(String destination, String source, String routingKey)	Unbind an exchange from an exchange.
RabbitMQClient	RabbitMQClient.exchangeUnbindAndForget(String destination, String source, String routingKey, Map<String,Object> arguments)	Unbind an exchange from an exchange.
RabbitMQClient	RabbitMQClient.messageCountAndForget(String queue)	Returns the number of messages in a queue ready to be delivered.
static RabbitMQClient	RabbitMQClient.newInstance(io.vertx.rabbitmq.RabbitMQClient delegate)	Creates a new instance of the RabbitMQClient.
RabbitMQClient	RabbitMQClient.queueBindAndForget(String queue, String exchange, String routingKey)	Bind a queue to an exchange
RabbitMQClient	RabbitMQClient.queueBindAndForget(String queue, String exchange, String routingKey, Map<String,Object> arguments)	Bind a queue to an exchange
RabbitMQClient	RabbitMQClient.queueDeclareAndForget(String queue, boolean durable, boolean exclusive, boolean autoDelete)	Declare a queue
RabbitMQClient	RabbitMQClient.queueDeclareAndForget(String queue, boolean durable, boolean exclusive, boolean autoDelete, io.vertx.core.json.JsonObject config)	Declare a queue with config options
RabbitMQClient	RabbitMQClient.queueDeclareAutoAndForget()	Actively declare a server-named exclusive, autodelete, non-durable queue.
RabbitMQClient	RabbitMQClient.queueDeleteAndForget(String queue)	Delete a queue, without regard for whether it is in use or has messages on it
RabbitMQClient	RabbitMQClient.queueDeleteIfAndForget(String queue, boolean ifUnused, boolean ifEmpty)	Delete a queue
RabbitMQClient	RabbitMQClient.queueUnbindAndForget(String queue, String exchange, String routingKey)	Unbind a queue from an exchange
RabbitMQClient	RabbitMQClient.queueUnbindAndForget(String queue, String exchange, String routingKey, Map<String,Object> arguments)	Unbind a queue from an exchange
RabbitMQClient	RabbitMQClient.restartConnectAndForget(int attempts)	restart the rabbitMQ connect.
RabbitMQClient	RabbitMQClient.startAndForget()	Start the rabbitMQ client.
RabbitMQClient	RabbitMQClient.stopAndForget()	Stop the rabbitMQ client.
RabbitMQClient	RabbitMQClient.waitForConfirmsAndForget()	Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
RabbitMQClient	RabbitMQClient.waitForConfirmsAndForget(long timeout)	Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.

Methods in io.vertx.mutiny.rabbitmq with parameters of type RabbitMQClient

Modifier and Type	Method	Description
static RabbitMQPublisher	RabbitMQPublisher.create(Vertx vertx, RabbitMQClient client, io.vertx.rabbitmq.RabbitMQPublisherOptions options)	Create and return a publisher using the specified client.