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 null
options
- 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 null
completionHandler
- 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 null
public Single<AmqpReceiver> rxCreateReceiver(String address)
AmqpReceiver.connection()
.address
- The source address to attach the consumer to, must not be null
public 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 null
completionHandler
- The handler called with the sender, once openedpublic AmqpClient createSender(String address)
address
- The target address to attach to, must not be null
public Single<AmqpSender> rxCreateSender(String address)
address
- The target address to attach to, must not be null
public AmqpClient createSender(String address, AmqpSenderOptions options, Handler<AsyncResult<AmqpSender>> completionHandler)
address
- The target address to attach to, must not be null
options
- 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 null
options
- The options for this sender.public Single<AmqpSender> rxCreateSender(String address, AmqpSenderOptions options)
address
- The target address to attach to, must not be null
options
- The options for this sender.public static AmqpClient newInstance(AmqpClient arg)
Copyright © 2021 Eclipse. All rights reserved.