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.