public class AmqpClientImpl extends Object implements AmqpClient
| Constructor and Description |
|---|
AmqpClientImpl(Vertx vertx,
AmqpClientOptions options,
boolean mustCloseVertxOnClose) |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
close()
Like
AmqpClient.close(Handler) but returns a Future of the asynchronous result |
void |
close(Handler<AsyncResult<Void>> handler)
Closes the client.
|
Future<AmqpConnection> |
connect()
Like
AmqpClient.connect(Handler) but returns a Future of the asynchronous result |
AmqpClient |
connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
Connects to the AMQP broker or router.
|
Future<AmqpReceiver> |
createReceiver(String address)
Like
AmqpClient.createReceiver(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
createReceiver(String address,
AmqpReceiverOptions receiverOptions)
Like
AmqpClient.createReceiver(String, AmqpReceiverOptions, Handler) but returns a Future of the asynchronous result |
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.
|
Future<AmqpSender> |
createSender(String address)
Like
AmqpClient.createSender(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
createSender(String address,
AmqpSenderOptions options)
Like
AmqpClient.createSender(String, AmqpSenderOptions, Handler) but returns a Future of the asynchronous result |
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 Future<AmqpConnection> connect()
AmqpClientAmqpClient.connect(Handler) but returns a Future of the asynchronous resultconnect in interface AmqpClientpublic void close(Handler<AsyncResult<Void>> handler)
AmqpClientclose in interface AmqpClienthandler - the close handler notified when the operation completes. It can be null.public Future<Void> close()
AmqpClientAmqpClient.close(Handler) but returns a Future of the asynchronous resultclose in interface AmqpClientpublic 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 Future<AmqpReceiver> createReceiver(String address)
AmqpClientAmqpClient.createReceiver(String, Handler) but returns a Future of the asynchronous resultcreateReceiver in interface AmqpClientpublic 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 Future<AmqpReceiver> createReceiver(String address, AmqpReceiverOptions receiverOptions)
AmqpClientAmqpClient.createReceiver(String, AmqpReceiverOptions, Handler) but returns a Future of the asynchronous resultcreateReceiver in interface AmqpClientpublic 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 Future<AmqpSender> createSender(String address)
AmqpClientAmqpClient.createSender(String, Handler) but returns a Future of the asynchronous resultcreateSender in interface AmqpClientpublic 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 openedpublic Future<AmqpSender> createSender(String address, AmqpSenderOptions options)
AmqpClientAmqpClient.createSender(String, AmqpSenderOptions, Handler) but returns a Future of the asynchronous resultcreateSender in interface AmqpClientCopyright © 2021. All rights reserved.