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) |
Completable |
publish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
int |
queueSize()
Get the number of published, but not sent, messages.
|
void |
restart()
Undo the effects of calling
stop() so that publish may be called again. |
Completable |
rxPublish(String exchange,
String routingKey,
com.rabbitmq.client.BasicProperties properties,
Buffer body)
Publish a message.
|
Completable |
rxStart()
Start the rabbitMQ publisher.
|
Completable |
rxStop()
Stop the rabbitMQ publisher.
|
Completable |
start()
Start the rabbitMQ publisher.
|
Completable |
stop()
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 Completable start()
public Completable rxStart()
public Completable stop()
public Completable rxStop()
public void restart()
public ReadStream<RabbitMQPublisherConfirmation> getConfirmationStream()
public int queueSize()
public Completable publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
exchange
- routingKey
- properties
- body
- public Completable rxPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body)
exchange
- routingKey
- properties
- body
- public static RabbitMQPublisher newInstance(RabbitMQPublisher arg)
Copyright © 2021 Eclipse. All rights reserved.