public class RabbitMQClient extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<RabbitMQClient> |
__TYPE_ARG |
Constructor and Description |
---|
RabbitMQClient(Object delegate) |
RabbitMQClient(io.vertx.rabbitmq.RabbitMQClient delegate) |
Modifier and Type | Method and Description |
---|---|
io.reactivex.rxjava3.core.Single<ReadStream<io.vertx.rabbitmq.RabbitMQConfirmation>> |
addConfirmListener(int maxQueueSize)
Add a Confirm Listener to the channel.
|
io.reactivex.rxjava3.core.Completable |
basicAck(long deliveryTag,
boolean multiple)
Acknowledge one or several received messages.
|
io.reactivex.rxjava3.core.Single<RabbitMQConsumer> |
basicConsumer(String queue) |
io.reactivex.rxjava3.core.Single<RabbitMQConsumer> |
basicConsumer(String queue,
io.vertx.rabbitmq.QueueOptions options)
Create a consumer with the given
options . |
io.reactivex.rxjava3.core.Single<RabbitMQMessage> |
basicGet(String queue,
boolean autoAck)
Retrieve a message from a queue using AMQP.Basic.Get
|
io.reactivex.rxjava3.core.Completable |
basicNack(long deliveryTag,
boolean multiple,
boolean requeue)
Reject one or several received messages.
|
io.reactivex.rxjava3.core.Completable |
basicPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
io.reactivex.rxjava3.core.Completable |
basicPublish(String exchange,
String routingKey,
Buffer body)
Publish a message.
|
io.reactivex.rxjava3.core.Completable |
basicPublishWithDeliveryTag(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
io.vertx.core.Handler<Long> deliveryTagHandler)
Publish a message.
|
io.reactivex.rxjava3.core.Completable |
basicQos(int prefetchCount)
Request a specific prefetchCount "quality of service" settings
for this channel.
|
io.reactivex.rxjava3.core.Completable |
basicQos(int prefetchCount,
boolean global)
Request a specific prefetchCount "quality of service" settings
for this channel.
|
io.reactivex.rxjava3.core.Completable |
basicQos(int prefetchSize,
int prefetchCount,
boolean global)
Request specific "quality of service" settings.
|
io.reactivex.rxjava3.core.Completable |
confirmSelect()
Enables publisher acknowledgements on this channel.
|
static RabbitMQClient |
create(Vertx vertx)
Create and return a client configured with the default options.
|
static RabbitMQClient |
create(Vertx vertx,
io.vertx.rabbitmq.RabbitMQOptions config)
Create and return a client.
|
boolean |
equals(Object o) |
io.reactivex.rxjava3.core.Completable |
exchangeBind(String destination,
String source,
String routingKey)
Bind an exchange to an exchange.
|
io.reactivex.rxjava3.core.Completable |
exchangeBind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
Bind an exchange to an exchange.
|
io.reactivex.rxjava3.core.Completable |
exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete)
Declare an exchange.
|
io.reactivex.rxjava3.core.Completable |
exchangeDeclare(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.
|
io.reactivex.rxjava3.core.Completable |
exchangeDelete(String exchange)
Delete an exchange, without regard for whether it is in use or not.
|
io.reactivex.rxjava3.core.Completable |
exchangeUnbind(String destination,
String source,
String routingKey)
Unbind an exchange from an exchange.
|
io.reactivex.rxjava3.core.Completable |
exchangeUnbind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
Unbind an exchange from an exchange.
|
io.vertx.rabbitmq.RabbitMQClient |
getDelegate() |
int |
hashCode() |
boolean |
isConnected()
Check if a connection is open
|
boolean |
isOpenChannel()
Check if a channel is open
|
io.reactivex.rxjava3.core.Single<Long> |
messageCount(String queue)
Returns the number of messages in a queue ready to be delivered.
|
static RabbitMQClient |
newInstance(io.vertx.rabbitmq.RabbitMQClient arg) |
io.reactivex.rxjava3.core.Completable |
queueBind(String queue,
String exchange,
String routingKey)
Bind a queue to an exchange
|
io.reactivex.rxjava3.core.Completable |
queueBind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
Bind a queue to an exchange
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete)
Declare a queue
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
io.vertx.core.json.JsonObject config)
Declare a queue with config options
|
io.reactivex.rxjava3.core.Single<io.vertx.core.json.JsonObject> |
queueDeclareAuto()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> |
queueDelete(String queue)
Delete a queue, without regard for whether it is in use or has messages on it
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> |
queueDeleteIf(String queue,
boolean ifUnused,
boolean ifEmpty)
Delete a queue
|
io.reactivex.rxjava3.core.Completable |
queueUnbind(String queue,
String exchange,
String routingKey)
Unbind a queue from an exchange
|
io.reactivex.rxjava3.core.Completable |
queueUnbind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
Unbind a queue from an exchange
|
io.reactivex.rxjava3.core.Single<ReadStream<io.vertx.rabbitmq.RabbitMQConfirmation>> |
rxAddConfirmListener(int maxQueueSize)
Add a Confirm Listener to the channel.
|
io.reactivex.rxjava3.core.Completable |
rxBasicAck(long deliveryTag,
boolean multiple)
Acknowledge one or several received messages.
|
io.reactivex.rxjava3.core.Single<RabbitMQConsumer> |
rxBasicConsumer(String queue) |
io.reactivex.rxjava3.core.Single<RabbitMQConsumer> |
rxBasicConsumer(String queue,
io.vertx.rabbitmq.QueueOptions options)
Create a consumer with the given
options . |
io.reactivex.rxjava3.core.Single<RabbitMQMessage> |
rxBasicGet(String queue,
boolean autoAck)
Retrieve a message from a queue using AMQP.Basic.Get
|
io.reactivex.rxjava3.core.Completable |
rxBasicNack(long deliveryTag,
boolean multiple,
boolean requeue)
Reject one or several received messages.
|
io.reactivex.rxjava3.core.Completable |
rxBasicPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
io.reactivex.rxjava3.core.Completable |
rxBasicPublish(String exchange,
String routingKey,
Buffer body)
Publish a message.
|
io.reactivex.rxjava3.core.Completable |
rxBasicPublishWithDeliveryTag(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
io.vertx.core.Handler<Long> deliveryTagHandler)
Publish a message.
|
io.reactivex.rxjava3.core.Completable |
rxBasicQos(int prefetchCount)
Request a specific prefetchCount "quality of service" settings
for this channel.
|
io.reactivex.rxjava3.core.Completable |
rxBasicQos(int prefetchCount,
boolean global)
Request a specific prefetchCount "quality of service" settings
for this channel.
|
io.reactivex.rxjava3.core.Completable |
rxBasicQos(int prefetchSize,
int prefetchCount,
boolean global)
Request specific "quality of service" settings.
|
io.reactivex.rxjava3.core.Completable |
rxConfirmSelect()
Enables publisher acknowledgements on this channel.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeBind(String destination,
String source,
String routingKey)
Bind an exchange to an exchange.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeBind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
Bind an exchange to an exchange.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete)
Declare an exchange.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeDeclare(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.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeDelete(String exchange)
Delete an exchange, without regard for whether it is in use or not.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeUnbind(String destination,
String source,
String routingKey)
Unbind an exchange from an exchange.
|
io.reactivex.rxjava3.core.Completable |
rxExchangeUnbind(String destination,
String source,
String routingKey,
Map<String,Object> arguments)
Unbind an exchange from an exchange.
|
io.reactivex.rxjava3.core.Single<Long> |
rxMessageCount(String queue)
Returns the number of messages in a queue ready to be delivered.
|
io.reactivex.rxjava3.core.Completable |
rxQueueBind(String queue,
String exchange,
String routingKey)
Bind a queue to an exchange
|
io.reactivex.rxjava3.core.Completable |
rxQueueBind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
Bind a queue to an exchange
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
rxQueueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete)
Declare a queue
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
rxQueueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
io.vertx.core.json.JsonObject config)
Declare a queue with config options
|
io.reactivex.rxjava3.core.Single<io.vertx.core.json.JsonObject> |
rxQueueDeclareAuto()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> |
rxQueueDelete(String queue)
Delete a queue, without regard for whether it is in use or has messages on it
|
io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> |
rxQueueDeleteIf(String queue,
boolean ifUnused,
boolean ifEmpty)
Delete a queue
|
io.reactivex.rxjava3.core.Completable |
rxQueueUnbind(String queue,
String exchange,
String routingKey)
Unbind a queue from an exchange
|
io.reactivex.rxjava3.core.Completable |
rxQueueUnbind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments)
Unbind a queue from an exchange
|
io.reactivex.rxjava3.core.Completable |
rxStart()
Start the rabbitMQ client.
|
io.reactivex.rxjava3.core.Completable |
rxStop()
Stop the rabbitMQ client.
|
io.reactivex.rxjava3.core.Completable |
rxWaitForConfirms()
Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
|
io.reactivex.rxjava3.core.Completable |
rxWaitForConfirms(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.
|
io.reactivex.rxjava3.core.Completable |
start()
Start the rabbitMQ client.
|
io.reactivex.rxjava3.core.Completable |
stop()
Stop the rabbitMQ client.
|
String |
toString() |
io.reactivex.rxjava3.core.Completable |
waitForConfirms()
Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
|
io.reactivex.rxjava3.core.Completable |
waitForConfirms(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.
|
public static final TypeArg<RabbitMQClient> __TYPE_ARG
public RabbitMQClient(io.vertx.rabbitmq.RabbitMQClient delegate)
public RabbitMQClient(Object delegate)
public io.vertx.rabbitmq.RabbitMQClient getDelegate()
public static RabbitMQClient create(Vertx vertx)
vertx
- the vertx instancepublic static RabbitMQClient create(Vertx vertx, io.vertx.rabbitmq.RabbitMQOptions config)
vertx
- the vertx instanceconfig
- the client configpublic io.reactivex.rxjava3.core.Completable basicAck(long deliveryTag, boolean multiple)
deliveryTag
- multiple
- public io.reactivex.rxjava3.core.Completable rxBasicAck(long deliveryTag, boolean multiple)
deliveryTag
- multiple
- public io.reactivex.rxjava3.core.Completable basicNack(long deliveryTag, boolean multiple, boolean requeue)
deliveryTag
- multiple
- requeue
- public io.reactivex.rxjava3.core.Completable rxBasicNack(long deliveryTag, boolean multiple, boolean requeue)
deliveryTag
- multiple
- requeue
- public io.reactivex.rxjava3.core.Single<RabbitMQMessage> basicGet(String queue, boolean autoAck)
queue
- autoAck
- public io.reactivex.rxjava3.core.Single<RabbitMQMessage> rxBasicGet(String queue, boolean autoAck)
queue
- autoAck
- public io.reactivex.rxjava3.core.Single<RabbitMQConsumer> basicConsumer(String queue)
queue
- public io.reactivex.rxjava3.core.Single<RabbitMQConsumer> rxBasicConsumer(String queue)
queue
- public io.reactivex.rxjava3.core.Single<RabbitMQConsumer> basicConsumer(String queue, io.vertx.rabbitmq.QueueOptions options)
options
.queue
- the name of a queueoptions
- options for queuepublic io.reactivex.rxjava3.core.Single<RabbitMQConsumer> rxBasicConsumer(String queue, io.vertx.rabbitmq.QueueOptions options)
options
.queue
- the name of a queueoptions
- options for queuepublic io.reactivex.rxjava3.core.Completable basicPublish(String exchange, String routingKey, Buffer body)
exchange
- routingKey
- body
- public io.reactivex.rxjava3.core.Completable rxBasicPublish(String exchange, String routingKey, Buffer body)
exchange
- routingKey
- body
- public io.reactivex.rxjava3.core.Single<ReadStream<io.vertx.rabbitmq.RabbitMQConfirmation>> addConfirmListener(int maxQueueSize)
maxQueueSize
- maximum size of the queue of confirmationspublic io.reactivex.rxjava3.core.Single<ReadStream<io.vertx.rabbitmq.RabbitMQConfirmation>> rxAddConfirmListener(int maxQueueSize)
maxQueueSize
- maximum size of the queue of confirmationspublic io.reactivex.rxjava3.core.Completable confirmSelect()
public io.reactivex.rxjava3.core.Completable rxConfirmSelect()
public io.reactivex.rxjava3.core.Completable waitForConfirms()
public io.reactivex.rxjava3.core.Completable rxWaitForConfirms()
public io.reactivex.rxjava3.core.Completable waitForConfirms(long timeout)
timeout
- public io.reactivex.rxjava3.core.Completable rxWaitForConfirms(long timeout)
timeout
- public io.reactivex.rxjava3.core.Completable basicQos(int prefetchCount)
prefetchCount
- maximum number of messages that the server will deliver, 0 if unlimitedpublic io.reactivex.rxjava3.core.Completable rxBasicQos(int prefetchCount)
prefetchCount
- maximum number of messages that the server will deliver, 0 if unlimitedpublic io.reactivex.rxjava3.core.Completable basicQos(int prefetchCount, boolean global)
prefetchCount
- maximum number of messages that the server will deliver, 0 if unlimitedglobal
- true if the settings should be applied to the entire channel rather than each consumerpublic io.reactivex.rxjava3.core.Completable rxBasicQos(int prefetchCount, boolean global)
prefetchCount
- maximum number of messages that the server will deliver, 0 if unlimitedglobal
- true if the settings should be applied to the entire channel rather than each consumerpublic io.reactivex.rxjava3.core.Completable basicQos(int prefetchSize, int prefetchCount, boolean global)
prefetchSize
- maximum amount of content (measured in octets) that the server will deliver, 0 if unlimitedprefetchCount
- maximum number of messages that the server will deliver, 0 if unlimitedglobal
- true if the settings should be applied to the entire channel rather than each consumerpublic io.reactivex.rxjava3.core.Completable rxBasicQos(int prefetchSize, int prefetchCount, boolean global)
prefetchSize
- maximum amount of content (measured in octets) that the server will deliver, 0 if unlimitedprefetchCount
- maximum number of messages that the server will deliver, 0 if unlimitedglobal
- true if the settings should be applied to the entire channel rather than each consumerpublic io.reactivex.rxjava3.core.Completable exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete)
exchange
- type
- durable
- autoDelete
- public io.reactivex.rxjava3.core.Completable rxExchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete)
exchange
- type
- durable
- autoDelete
- public io.reactivex.rxjava3.core.Completable exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, io.vertx.core.json.JsonObject config)
exchange
- type
- durable
- autoDelete
- config
- public io.reactivex.rxjava3.core.Completable rxExchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, io.vertx.core.json.JsonObject config)
exchange
- type
- durable
- autoDelete
- config
- public io.reactivex.rxjava3.core.Completable exchangeDelete(String exchange)
exchange
- public io.reactivex.rxjava3.core.Completable rxExchangeDelete(String exchange)
exchange
- public io.reactivex.rxjava3.core.Completable exchangeBind(String destination, String source, String routingKey)
destination
- source
- routingKey
- public io.reactivex.rxjava3.core.Completable rxExchangeBind(String destination, String source, String routingKey)
destination
- source
- routingKey
- public io.reactivex.rxjava3.core.Completable exchangeBind(String destination, String source, String routingKey, Map<String,Object> arguments)
destination
- source
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Completable rxExchangeBind(String destination, String source, String routingKey, Map<String,Object> arguments)
destination
- source
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Completable exchangeUnbind(String destination, String source, String routingKey)
destination
- source
- routingKey
- public io.reactivex.rxjava3.core.Completable rxExchangeUnbind(String destination, String source, String routingKey)
destination
- source
- routingKey
- public io.reactivex.rxjava3.core.Completable exchangeUnbind(String destination, String source, String routingKey, Map<String,Object> arguments)
destination
- source
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Completable rxExchangeUnbind(String destination, String source, String routingKey, Map<String,Object> arguments)
destination
- source
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Single<io.vertx.core.json.JsonObject> queueDeclareAuto()
public io.reactivex.rxjava3.core.Single<io.vertx.core.json.JsonObject> rxQueueDeclareAuto()
public io.reactivex.rxjava3.core.Completable queueBind(String queue, String exchange, String routingKey)
queue
- exchange
- routingKey
- public io.reactivex.rxjava3.core.Completable rxQueueBind(String queue, String exchange, String routingKey)
queue
- exchange
- routingKey
- public io.reactivex.rxjava3.core.Completable queueBind(String queue, String exchange, String routingKey, Map<String,Object> arguments)
queue
- exchange
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Completable rxQueueBind(String queue, String exchange, String routingKey, Map<String,Object> arguments)
queue
- exchange
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Completable queueUnbind(String queue, String exchange, String routingKey)
queue
- exchange
- routingKey
- public io.reactivex.rxjava3.core.Completable rxQueueUnbind(String queue, String exchange, String routingKey)
queue
- exchange
- routingKey
- public io.reactivex.rxjava3.core.Completable queueUnbind(String queue, String exchange, String routingKey, Map<String,Object> arguments)
queue
- exchange
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Completable rxQueueUnbind(String queue, String exchange, String routingKey, Map<String,Object> arguments)
queue
- exchange
- routingKey
- arguments
- public io.reactivex.rxjava3.core.Single<Long> messageCount(String queue)
queue
- public io.reactivex.rxjava3.core.Single<Long> rxMessageCount(String queue)
queue
- public io.reactivex.rxjava3.core.Completable start()
public io.reactivex.rxjava3.core.Completable rxStart()
public io.reactivex.rxjava3.core.Completable stop()
public io.reactivex.rxjava3.core.Completable rxStop()
public boolean isConnected()
public boolean isOpenChannel()
public io.reactivex.rxjava3.core.Completable basicPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
exchange
- routingKey
- properties
- body
- public io.reactivex.rxjava3.core.Completable rxBasicPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
exchange
- routingKey
- properties
- body
- public io.reactivex.rxjava3.core.Completable basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, io.vertx.core.Handler<Long> deliveryTagHandler)
exchange
- routingKey
- properties
- body
- deliveryTagHandler
- callback to capture the deliveryTag for this message. Note that this will be called synchronously in the context of the client before the result is known.public io.reactivex.rxjava3.core.Completable rxBasicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, io.vertx.core.Handler<Long> deliveryTagHandler)
exchange
- routingKey
- properties
- body
- deliveryTagHandler
- callback to capture the deliveryTag for this message. Note that this will be called synchronously in the context of the client before the result is known.public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete)
queue
- durable
- exclusive
- autoDelete
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> rxQueueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete)
queue
- durable
- exclusive
- autoDelete
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, io.vertx.core.json.JsonObject config)
queue
- durable
- exclusive
- autoDelete
- config
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> rxQueueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, io.vertx.core.json.JsonObject config)
queue
- durable
- exclusive
- autoDelete
- config
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> queueDelete(String queue)
queue
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> rxQueueDelete(String queue)
queue
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> queueDeleteIf(String queue, boolean ifUnused, boolean ifEmpty)
queue
- ifUnused
- ifEmpty
- public io.reactivex.rxjava3.core.Single<com.rabbitmq.client.AMQP.Queue.DeleteOk> rxQueueDeleteIf(String queue, boolean ifUnused, boolean ifEmpty)
queue
- ifUnused
- ifEmpty
- public static RabbitMQClient newInstance(io.vertx.rabbitmq.RabbitMQClient arg)
Copyright © 2022 Eclipse. All rights reserved.