public class AmqpClient extends Object
AmqpClient and connect to a broker and server.
NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<AmqpClient> |
__TYPE_ARG |
| Constructor and Description |
|---|
AmqpClient(AmqpClient delegate) |
AmqpClient(Object delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes the client.
|
void |
close(Handler<AsyncResult<Void>> closeHandler)
Closes the client.
|
AmqpClient |
connect()
Connects to the AMQP broker or router.
|
AmqpClient |
connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
Connects to the AMQP broker or router.
|
static AmqpClient |
create(AmqpClientOptions options)
Creates a new instance of
AmqpClient using an internal Vert.x instance (with default configuration) and
the given AMQP client configuration. |
static AmqpClient |
create(Vertx vertx,
AmqpClientOptions options)
Creates a new instance of
AmqpClient with the given Vert.x instance and the given options. |
AmqpClient |
createReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
AmqpClient |
createReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
AmqpClient |
createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpClient |
createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpClient |
createSender(String address)
Creates a sender used to send messages to the given address.
|
AmqpClient |
createSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
AmqpClient |
createSender(String address,
AmqpSenderOptions options,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpClient |
createSender(String address,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
boolean |
equals(Object o) |
AmqpClient |
getDelegate() |
int |
hashCode() |
static AmqpClient |
newInstance(AmqpClient arg) |
Completable |
rxClose()
Closes the client.
|
Single<AmqpConnection> |
rxConnect()
Connects to the AMQP broker or router.
|
Single<AmqpReceiver> |
rxCreateReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
Single<AmqpReceiver> |
rxCreateReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Single<AmqpSender> |
rxCreateSender(String address)
Creates a sender used to send messages to the given address.
|
Single<AmqpSender> |
rxCreateSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<AmqpClient> __TYPE_ARG
public AmqpClient(AmqpClient delegate)
public AmqpClient(Object delegate)
public AmqpClient getDelegate()
public static AmqpClient create(AmqpClientOptions options)
AmqpClient using an internal Vert.x instance (with default configuration) and
the given AMQP client configuration. Note that the created Vert.x instance will be closed when the client is
closed.options - the AMQP client options, may be null falling back to the default configurationpublic static AmqpClient create(Vertx vertx, AmqpClientOptions options)
AmqpClient with the given Vert.x instance and the given options.vertx - the vert.x instance, must not be nulloptions - the AMQP options, may be @{code null} falling back to the default configurationpublic AmqpClient connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
AmqpClientOptions as well as the
potential credential required.connectionHandler - handler that will process the result, giving either the connection or failure cause. Must not be null.public AmqpClient connect()
AmqpClientOptions as well as the
potential credential required.public Single<AmqpConnection> rxConnect()
AmqpClientOptions as well as the
potential credential required.public void close(Handler<AsyncResult<Void>> closeHandler)
closeHandler - the close handler notified when the operation completes. It can be null.public void close()
public Completable rxClose()
public AmqpClient createReceiver(String address, Handler<AsyncResult<AmqpReceiver>> completionHandler)
AmqpReceiver.connection().address - The source address to attach the consumer to, must not be nullcompletionHandler - the handler called with the receiver. The receiver has been opened.public AmqpClient createReceiver(String address)
AmqpReceiver.connection().address - The source address to attach the consumer to, must not be nullpublic Single<AmqpReceiver> rxCreateReceiver(String address)
AmqpReceiver.connection().address - The source address to attach the consumer to, must not be nullpublic AmqpClient createReceiver(String address, AmqpReceiverOptions receiverOptions, Handler<AsyncResult<AmqpReceiver>> completionHandler)
AmqpReceiver.connection().address - The source address to attach the consumer to.receiverOptions - The options for this receiver.completionHandler - The handler called with the receiver, once opened. Note that the messageHandler can be called before the completionHandler if messages are awaiting delivery.public AmqpClient createReceiver(String address, AmqpReceiverOptions receiverOptions)
AmqpReceiver.connection().address - The source address to attach the consumer to.receiverOptions - The options for this receiver.public Single<AmqpReceiver> rxCreateReceiver(String address, AmqpReceiverOptions receiverOptions)
AmqpReceiver.connection().address - The source address to attach the consumer to.receiverOptions - The options for this receiver.public AmqpClient createSender(String address, Handler<AsyncResult<AmqpSender>> completionHandler)
address - The target address to attach to, must not be nullcompletionHandler - The handler called with the sender, once openedpublic AmqpClient createSender(String address)
address - The target address to attach to, must not be nullpublic Single<AmqpSender> rxCreateSender(String address)
address - The target address to attach to, must not be nullpublic AmqpClient createSender(String address, AmqpSenderOptions options, Handler<AsyncResult<AmqpSender>> completionHandler)
address - The target address to attach to, must not be nulloptions - The options for this sender.completionHandler - The handler called with the sender, once openedpublic AmqpClient createSender(String address, AmqpSenderOptions options)
address - The target address to attach to, must not be nulloptions - The options for this sender.public Single<AmqpSender> rxCreateSender(String address, AmqpSenderOptions options)
address - The target address to attach to, must not be nulloptions - The options for this sender.public static AmqpClient newInstance(AmqpClient arg)
Copyright © 2021 Eclipse. All rights reserved.