open class RabbitMQClient
NOTE: This class has been automatically generated from the io.vertx.rabbitmq.RabbitMQClient non RX-ified interface using Vert.x codegen.
RabbitMQClient(delegate: RabbitMQClient) |
static val __TYPE_ARG: TypeArg<RabbitMQClient> |
open fun basicAck(deliveryTag: Long, multiple: Boolean, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Acknowledge one or several received messages. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the received message being acknowledged. |
|
open fun basicConsume(queue: String, address: String, resultHandler: Handler<AsyncResult<Void>>): Unit
Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag. open fun basicConsume(queue: String, address: String, autoAck: Boolean, resultHandler: Handler<AsyncResult<Void>>): Unit
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag. open fun basicConsume(queue: String, address: String, autoAck: Boolean, resultHandler: Handler<AsyncResult<Void>>, errorHandler: Handler<Throwable>): Unit
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and error handler |
|
open fun basicGet(queue: String, autoAck: Boolean, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Retrieve a message from a queue using AMQP.Basic.Get |
|
open fun basicNack(deliveryTag: Long, multiple: Boolean, requeue: Boolean, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Reject one or several received messages. |
|
open fun basicPublish(exchange: String, routingKey: String, message: JsonObject, resultHandler: Handler<AsyncResult<Void>>): Unit
Publish a message. Publishing to a non-existent exchange will result in a channel-level protocol exception, which closes the channel. Invocations of Channel#basicPublish will eventually block if a resource-driven alarm is in effect. |
|
open fun basicQos(prefetchCount: Int, resultHandler: Handler<AsyncResult<Void>>): Unit
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on a channel (or connection). This limit is applied separately to each new consumer on the channel. |
|
open fun confirmSelect(resultHandler: Handler<AsyncResult<Void>>): Unit
Enables publisher acknowledgements on this channel. Can be called once during client initialisation. Calls to basicPublish() will have to be confirmed. |
|
open static fun create(vertx: Vertx, config: RabbitMQOptions): RabbitMQClient
Create and return a client. |
|
open fun equals(other: Any?): Boolean |
|
open fun exchangeBind(destination: String, source: String, routingKey: String, resultHandler: Handler<AsyncResult<Void>>): Unit
Bind an exchange to an exchange. |
|
open fun exchangeDeclare(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, resultHandler: Handler<AsyncResult<Void>>): Unit
Declare an exchange. open fun exchangeDeclare(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: MutableMap<String, String>, resultHandler: Handler<AsyncResult<Void>>): Unit
Declare an exchange with additional parameters such as dead lettering or an alternate exchnage. |
|
open fun exchangeDelete(exchange: String, resultHandler: Handler<AsyncResult<Void>>): Unit
Delete an exchange, without regard for whether it is in use or not. |
|
open fun exchangeUnbind(destination: String, source: String, routingKey: String, resultHandler: Handler<AsyncResult<Void>>): Unit
Unbind an exchange from an exchange. |
|
open fun getDelegate(): RabbitMQClient |
|
open fun hashCode(): Int |
|
open fun isConnected(): Boolean
Check if a connection is open |
|
open fun isOpenChannel(): Boolean
Check if a channel is open |
|
open fun messageCount(queue: String, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Returns the number of messages in a queue ready to be delivered. |
|
open static fun newInstance(arg: RabbitMQClient): RabbitMQClient |
|
open fun queueBind(queue: String, exchange: String, routingKey: String, resultHandler: Handler<AsyncResult<Void>>): Unit
Bind a queue to an exchange |
|
open fun queueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Declare a queue open fun queueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: MutableMap<String, String>, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Declare a queue with config options |
|
open fun queueDeclareAuto(resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Actively declare a server-named exclusive, autodelete, non-durable queue. |
|
open fun queueDelete(queue: String, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Delete a queue, without regard for whether it is in use or has messages on it |
|
open fun queueDeleteIf(queue: String, ifUnused: Boolean, ifEmpty: Boolean, resultHandler: Handler<AsyncResult<JsonObject>>): Unit
Delete a queue |
|
open fun rxBasicAck(deliveryTag: Long, multiple: Boolean): Single<JsonObject>
Acknowledge one or several received messages. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the received message being acknowledged. |
|
open fun rxBasicConsume(queue: String, address: String): Completable
Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag. open fun rxBasicConsume(queue: String, address: String, autoAck: Boolean): Completable
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag. |
|
open fun rxBasicGet(queue: String, autoAck: Boolean): Single<JsonObject>
Retrieve a message from a queue using AMQP.Basic.Get |
|
open fun rxBasicNack(deliveryTag: Long, multiple: Boolean, requeue: Boolean): Single<JsonObject>
Reject one or several received messages. |
|
open fun rxBasicPublish(exchange: String, routingKey: String, message: JsonObject): Completable
Publish a message. Publishing to a non-existent exchange will result in a channel-level protocol exception, which closes the channel. Invocations of Channel#basicPublish will eventually block if a resource-driven alarm is in effect. |
|
open fun rxBasicQos(prefetchCount: Int): Completable
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on a channel (or connection). This limit is applied separately to each new consumer on the channel. |
|
open fun rxConfirmSelect(): Completable
Enables publisher acknowledgements on this channel. Can be called once during client initialisation. Calls to basicPublish() will have to be confirmed. |
|
open fun rxExchangeBind(destination: String, source: String, routingKey: String): Completable
Bind an exchange to an exchange. |
|
open fun rxExchangeDeclare(exchange: String, type: String, durable: Boolean, autoDelete: Boolean): Completable
Declare an exchange. open fun rxExchangeDeclare(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: MutableMap<String, String>): Completable
Declare an exchange with additional parameters such as dead lettering or an alternate exchnage. |
|
open fun rxExchangeDelete(exchange: String): Completable
Delete an exchange, without regard for whether it is in use or not. |
|
open fun rxExchangeUnbind(destination: String, source: String, routingKey: String): Completable
Unbind an exchange from an exchange. |
|
open fun rxMessageCount(queue: String): Single<JsonObject>
Returns the number of messages in a queue ready to be delivered. |
|
open fun rxQueueBind(queue: String, exchange: String, routingKey: String): Completable
Bind a queue to an exchange |
|
open fun rxQueueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean): Single<JsonObject>
Declare a queue open fun rxQueueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: MutableMap<String, String>): Single<JsonObject>
Declare a queue with config options |
|
open fun rxQueueDeclareAuto(): Single<JsonObject>
Actively declare a server-named exclusive, autodelete, non-durable queue. |
|
open fun rxQueueDelete(queue: String): Single<JsonObject>
Delete a queue, without regard for whether it is in use or has messages on it |
|
open fun rxQueueDeleteIf(queue: String, ifUnused: Boolean, ifEmpty: Boolean): Single<JsonObject>
Delete a queue |
|
open fun rxStart(): Completable
Start the rabbitMQ client. Create the connection and the chanel. |
|
open fun rxStop(): Completable
Stop the rabbitMQ client. Close the connection and its chanel. |
|
open fun rxWaitForConfirms(): Completable
Wait until all messages published since the last call have been either ack'd or nack'd by the broker. This will incur slight performance loss at the expense of higher write consistency. If desired, multiple calls to basicPublish() can be batched before confirming. open fun rxWaitForConfirms(timeout: Long): Completable
Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses. If the timeout expires a TimeoutException is thrown. |
|
open fun start(resultHandler: Handler<AsyncResult<Void>>): Unit
Start the rabbitMQ client. Create the connection and the chanel. |
|
open fun stop(resultHandler: Handler<AsyncResult<Void>>): Unit
Stop the rabbitMQ client. Close the connection and its chanel. |
|
open fun toString(): String |
|
open fun waitForConfirms(resultHandler: Handler<AsyncResult<Void>>): Unit
Wait until all messages published since the last call have been either ack'd or nack'd by the broker. This will incur slight performance loss at the expense of higher write consistency. If desired, multiple calls to basicPublish() can be batched before confirming. open fun waitForConfirms(timeout: Long, resultHandler: Handler<AsyncResult<Void>>): Unit
Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses. If the timeout expires a TimeoutException is thrown. |