public class RabbitMQPublisher extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<RabbitMQPublisher> |
__TYPE_ARG |
Constructor and Description |
---|
RabbitMQPublisher(Object delegate) |
RabbitMQPublisher(RabbitMQPublisher delegate) |
Modifier and Type | Method and Description |
---|---|
static RabbitMQPublisher |
create(Vertx vertx,
RabbitMQClient client,
RabbitMQPublisherOptions options)
Create and return a publisher using the specified client.
|
boolean |
equals(Object o) |
ReadStream<RabbitMQPublisherConfirmation> |
getConfirmationStream()
Get the ReadStream that contains the message IDs for confirmed messages.
|
RabbitMQPublisher |
getDelegate() |
int |
hashCode() |
static RabbitMQPublisher |
newInstance(RabbitMQPublisher arg) |
void |
publish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
void |
publish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
int |
queueSize()
Get the number of published, but not sent, messages.
|
void |
restart()
Undo the effects of calling
stop(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) so that publish may be called again. |
Single<Void> |
rxPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
Single<Void> |
rxStart()
Start the rabbitMQ publisher.
|
Single<Void> |
rxStop()
Stop the rabbitMQ publisher.
|
void |
start()
Start the rabbitMQ publisher.
|
void |
start(Handler<AsyncResult<Void>> resultHandler)
Start the rabbitMQ publisher.
|
void |
stop()
Stop the rabbitMQ publisher.
|
void |
stop(Handler<AsyncResult<Void>> resultHandler)
Stop the rabbitMQ publisher.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<RabbitMQPublisher> __TYPE_ARG
public RabbitMQPublisher(RabbitMQPublisher delegate)
public RabbitMQPublisher(Object delegate)
public RabbitMQPublisher getDelegate()
public static RabbitMQPublisher create(Vertx vertx, RabbitMQClient client, RabbitMQPublisherOptions options)
vertx
- the vertx instance.client
- the RabbitMQClient.options
- options for the publisher.public void start(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- public void start()
public Single<Void> rxStart()
public void stop(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- public void stop()
public Single<Void> rxStop()
public void restart()
stop(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
so that publish may be called again.
It is harmless to call restart() when stop(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
has not been called, however if restart() is called
whilst stop(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
is being processed the stop(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>)
will never complete.public ReadStream<RabbitMQPublisherConfirmation> getConfirmationStream()
public int queueSize()
public void publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<AsyncResult<Void>> resultHandler)
exchange
- routingKey
- properties
- body
- resultHandler
- public void publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
exchange
- routingKey
- properties
- body
- public Single<Void> rxPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
exchange
- routingKey
- properties
- body
- public static RabbitMQPublisher newInstance(RabbitMQPublisher arg)
Copyright © 2023 Eclipse. All rights reserved.