public class RabbitMQClient extends Object
original
non RX-ified interface using Vert.x codegen.Constructor and Description |
---|
RabbitMQClient(RabbitMQClient delegate) |
Modifier and Type | Method and Description |
---|---|
void |
basicAck(long deliveryTag,
boolean multiple,
Handler<AsyncResult<JsonObject>> resultHandler)
Acknowledge one or several received messages.
|
Observable<JsonObject> |
basicAckObservable(long deliveryTag,
boolean multiple)
Acknowledge one or several received messages.
|
void |
basicConsume(String queue,
String address,
boolean autoAck,
Handler<AsyncResult<Void>> resultHandler)
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
|
void |
basicConsume(String queue,
String address,
Handler<AsyncResult<Void>> resultHandler)
Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag.
|
Observable<Void> |
basicConsumeObservable(String queue,
String address)
Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag.
|
Observable<Void> |
basicConsumeObservable(String queue,
String address,
boolean autoAck)
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
|
void |
basicGet(String queue,
boolean autoAck,
Handler<AsyncResult<JsonObject>> resultHandler)
Retrieve a message from a queue using AMQP.Basic.Get
|
Observable<JsonObject> |
basicGetObservable(String queue,
boolean autoAck)
Retrieve a message from a queue using AMQP.Basic.Get
|
void |
basicNack(long deliveryTag,
boolean multiple,
boolean requeue,
Handler<AsyncResult<JsonObject>> resultHandler)
Reject one or several received messages.
|
Observable<JsonObject> |
basicNackObservable(long deliveryTag,
boolean multiple,
boolean requeue)
Reject one or several received messages.
|
void |
basicPublish(String exchange,
String routingKey,
JsonObject message,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
Observable<Void> |
basicPublishObservable(String exchange,
String routingKey,
JsonObject message)
Publish a message.
|
void |
basicQos(int prefetchCount,
Handler<AsyncResult<Void>> resultHandler)
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on
a channel (or connection).
|
Observable<Void> |
basicQosObservable(int prefetchCount)
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on
a channel (or connection).
|
static RabbitMQClient |
create(Vertx vertx,
JsonObject config) |
void |
exchangeBind(String destination,
String source,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Bind an exchange to an exchange.
|
Observable<Void> |
exchangeBindObservable(String destination,
String source,
String routingKey)
Bind an exchange to an exchange.
|
void |
exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
Handler<AsyncResult<Void>> resultHandler)
Declare an exchange.
|
Observable<Void> |
exchangeDeclareObservable(String exchange,
String type,
boolean durable,
boolean autoDelete)
Declare an exchange.
|
void |
exchangeDelete(String exchange,
Handler<AsyncResult<Void>> resultHandler)
Delete an exchange, without regard for whether it is in use or not.
|
Observable<Void> |
exchangeDeleteObservable(String exchange)
Delete an exchange, without regard for whether it is in use or not.
|
void |
exchangeUnbind(String destination,
String source,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Unbind an exchange from an exchange.
|
Observable<Void> |
exchangeUnbindObservable(String destination,
String source,
String routingKey)
Unbind an exchange from an exchange.
|
Object |
getDelegate() |
boolean |
isConnected()
Check if a connection is open
|
boolean |
isOpenChannel()
Check if a channel is open
|
void |
messageCount(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Returns the number of messages in a queue ready to be delivered.
|
Observable<JsonObject> |
messageCountObservable(String queue)
Returns the number of messages in a queue ready to be delivered.
|
static RabbitMQClient |
newInstance(RabbitMQClient arg) |
void |
queueBind(String queue,
String exchange,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Bind a queue to an exchange
|
Observable<Void> |
queueBindObservable(String queue,
String exchange,
String routingKey)
Bind a queue to an exchange
|
void |
queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Handler<AsyncResult<JsonObject>> resultHandler)
Declare a queue
|
void |
queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Observable<JsonObject> |
queueDeclareAutoObservable()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Observable<JsonObject> |
queueDeclareObservable(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete)
Declare a queue
|
void |
queueDelete(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue, without regard for whether it is in use or has messages on it
|
void |
queueDeleteIf(String queue,
boolean ifUnused,
boolean ifEmpty,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue
|
Observable<JsonObject> |
queueDeleteIfObservable(String queue,
boolean ifUnused,
boolean ifEmpty)
Delete a queue
|
Observable<JsonObject> |
queueDeleteObservable(String queue)
Delete a queue, without regard for whether it is in use or has messages on it
|
void |
start(Handler<AsyncResult<Void>> resultHandler)
Start the rabbitMQ client.
|
Observable<Void> |
startObservable()
Start the rabbitMQ client.
|
void |
stop(Handler<AsyncResult<Void>> resultHandler)
Stop the rabbitMQ client.
|
Observable<Void> |
stopObservable()
Stop the rabbitMQ client.
|
public RabbitMQClient(RabbitMQClient delegate)
public Object getDelegate()
public static RabbitMQClient create(Vertx vertx, JsonObject config)
public void basicAck(long deliveryTag, boolean multiple, Handler<AsyncResult<JsonObject>> resultHandler)
deliveryTag
- multiple
- resultHandler
- public Observable<JsonObject> basicAckObservable(long deliveryTag, boolean multiple)
deliveryTag
- multiple
- public void basicNack(long deliveryTag, boolean multiple, boolean requeue, Handler<AsyncResult<JsonObject>> resultHandler)
deliveryTag
- multiple
- requeue
- resultHandler
- public Observable<JsonObject> basicNackObservable(long deliveryTag, boolean multiple, boolean requeue)
deliveryTag
- multiple
- requeue
- public void basicGet(String queue, boolean autoAck, Handler<AsyncResult<JsonObject>> resultHandler)
queue
- autoAck
- resultHandler
- public Observable<JsonObject> basicGetObservable(String queue, boolean autoAck)
queue
- autoAck
- public void basicConsume(String queue, String address, Handler<AsyncResult<Void>> resultHandler)
queue
- address
- resultHandler
- public Observable<Void> basicConsumeObservable(String queue, String address)
queue
- address
- public void basicConsume(String queue, String address, boolean autoAck, Handler<AsyncResult<Void>> resultHandler)
queue
- address
- autoAck
- resultHandler
- public Observable<Void> basicConsumeObservable(String queue, String address, boolean autoAck)
queue
- address
- autoAck
- public void basicPublish(String exchange, String routingKey, JsonObject message, Handler<AsyncResult<Void>> resultHandler)
exchange
- routingKey
- message
- resultHandler
- public Observable<Void> basicPublishObservable(String exchange, String routingKey, JsonObject message)
exchange
- routingKey
- message
- public void basicQos(int prefetchCount, Handler<AsyncResult<Void>> resultHandler)
prefetchCount
- resultHandler
- public Observable<Void> basicQosObservable(int prefetchCount)
prefetchCount
- public void exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, Handler<AsyncResult<Void>> resultHandler)
exchange
- type
- durable
- autoDelete
- resultHandler
- public Observable<Void> exchangeDeclareObservable(String exchange, String type, boolean durable, boolean autoDelete)
exchange
- type
- durable
- autoDelete
- public void exchangeDelete(String exchange, Handler<AsyncResult<Void>> resultHandler)
exchange
- resultHandler
- public Observable<Void> exchangeDeleteObservable(String exchange)
exchange
- public void exchangeBind(String destination, String source, String routingKey, Handler<AsyncResult<Void>> resultHandler)
destination
- source
- routingKey
- resultHandler
- public Observable<Void> exchangeBindObservable(String destination, String source, String routingKey)
destination
- source
- routingKey
- public void exchangeUnbind(String destination, String source, String routingKey, Handler<AsyncResult<Void>> resultHandler)
destination
- source
- routingKey
- resultHandler
- public Observable<Void> exchangeUnbindObservable(String destination, String source, String routingKey)
destination
- source
- routingKey
- public void queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
resultHandler
- public Observable<JsonObject> queueDeclareAutoObservable()
public void queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Handler<AsyncResult<JsonObject>> resultHandler)
queue
- durable
- exclusive
- autoDelete
- resultHandler
- public Observable<JsonObject> queueDeclareObservable(String queue, boolean durable, boolean exclusive, boolean autoDelete)
queue
- durable
- exclusive
- autoDelete
- public void queueDelete(String queue, Handler<AsyncResult<JsonObject>> resultHandler)
queue
- resultHandler
- public Observable<JsonObject> queueDeleteObservable(String queue)
queue
- public void queueDeleteIf(String queue, boolean ifUnused, boolean ifEmpty, Handler<AsyncResult<JsonObject>> resultHandler)
queue
- ifUnused
- ifEmpty
- resultHandler
- public Observable<JsonObject> queueDeleteIfObservable(String queue, boolean ifUnused, boolean ifEmpty)
queue
- ifUnused
- ifEmpty
- public void queueBind(String queue, String exchange, String routingKey, Handler<AsyncResult<Void>> resultHandler)
queue
- exchange
- routingKey
- resultHandler
- public Observable<Void> queueBindObservable(String queue, String exchange, String routingKey)
queue
- exchange
- routingKey
- public void messageCount(String queue, Handler<AsyncResult<JsonObject>> resultHandler)
queue
- resultHandler
- public Observable<JsonObject> messageCountObservable(String queue)
queue
- public void start(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- public Observable<Void> startObservable()
public void stop(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- public Observable<Void> stopObservable()
public boolean isConnected()
public boolean isOpenChannel()
public static RabbitMQClient newInstance(RabbitMQClient arg)
Copyright © 2016. All rights reserved.