public class AmqpClientImpl extends Object implements AmqpClient
| Constructor and Description |
|---|
AmqpClientImpl(Vertx vertx,
AmqpClientOptions options,
boolean mustCloseVertxOnClose) |
| Modifier and Type | Method and Description |
|---|---|
void |
close(Handler<AsyncResult<Void>> handler)
Closes the client.
|
AmqpClient |
connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
Connects to the AMQP broker or router.
|
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,
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreate, createpublic AmqpClientImpl(Vertx vertx, AmqpClientOptions options, boolean mustCloseVertxOnClose)
public AmqpClient connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
AmqpClientAmqpClientOptions as well as the
potential credential required.connect in interface AmqpClientconnectionHandler - handler that will process the result, giving either the connection or failure cause. Must
not be null.public void close(Handler<AsyncResult<Void>> handler)
AmqpClientclose in interface AmqpClienthandler - the close handler notified when the operation completes. It can be null.public AmqpClient createReceiver(String address, Handler<AsyncResult<AmqpReceiver>> completionHandler)
AmqpClientAmqpReceiver.connection().createReceiver in interface AmqpClientaddress - 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, AmqpReceiverOptions receiverOptions, Handler<AsyncResult<AmqpReceiver>> completionHandler)
AmqpClientAmqpReceiver.connection().createReceiver in interface AmqpClientaddress - 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 createSender(String address, Handler<AsyncResult<AmqpSender>> completionHandler)
AmqpClientcreateSender in interface AmqpClientaddress - The target address to attach to, must not be nullcompletionHandler - The handler called with the sender, once openedpublic AmqpClient createSender(String address, AmqpSenderOptions options, Handler<AsyncResult<AmqpSender>> completionHandler)
AmqpClientcreateSender in interface AmqpClientaddress - The target address to attach to, must not be nulloptions - The options for this sender.completionHandler - The handler called with the sender, once openedCopyright © 2020. All rights reserved.