Uses of Class
io.vertx.reactivex.amqp.AmqpConnection

Packages that use AmqpConnection

Package	Description
io.vertx.reactivex.amqp

Uses of AmqpConnection in io.vertx.reactivex.amqp

Fields in io.vertx.reactivex.amqp with type parameters of type AmqpConnection

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<AmqpConnection>	AmqpConnection.__TYPE_ARG

Methods in io.vertx.reactivex.amqp that return AmqpConnection

Modifier and Type	Method and Description
AmqpConnection	AmqpConnection.close() Closes the AMQP connection, i.e.
AmqpConnection	AmqpConnection.close(Handler<AsyncResult<Void>> done) Closes the AMQP connection, i.e.
AmqpConnection	AmqpSender.connection() Gets the connection having created the sender.
AmqpConnection	AmqpReceiver.connection() Gets the connection having created the receiver.
AmqpConnection	AmqpConnection.createAnonymousSender() Creates an anonymous sender.
AmqpConnection	AmqpConnection.createAnonymousSender(Handler<AsyncResult<AmqpSender>> completionHandler) Creates an anonymous sender.
AmqpConnection	AmqpConnection.createDynamicReceiver() Creates a dynamic receiver.
AmqpConnection	AmqpConnection.createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>> completionHandler) Creates a dynamic receiver.
AmqpConnection	AmqpConnection.createReceiver(String address) Creates a receiver used to consume messages from the given address.
AmqpConnection	AmqpConnection.createReceiver(String address, AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.
AmqpConnection	AmqpConnection.createReceiver(String address, AmqpReceiverOptions receiverOptions, Handler<AsyncResult<AmqpReceiver>> completionHandler) Creates a receiver used to consumer messages from the given address.
AmqpConnection	AmqpConnection.createReceiver(String address, Handler<AsyncResult<AmqpReceiver>> completionHandler) Creates a receiver used to consume messages from the given address.
AmqpConnection	AmqpConnection.createSender(String address) Creates a sender used to send messages to the given address.
AmqpConnection	AmqpConnection.createSender(String address, AmqpSenderOptions options) Creates a sender used to send messages to the given address.
AmqpConnection	AmqpConnection.createSender(String address, AmqpSenderOptions options, Handler<AsyncResult<AmqpSender>> completionHandler) Creates a sender used to send messages to the given address.
AmqpConnection	AmqpConnection.createSender(String address, Handler<AsyncResult<AmqpSender>> completionHandler) Creates a sender used to send messages to the given address.
AmqpConnection	AmqpConnection.exceptionHandler(Handler<Throwable> handler) Registers a handler called on disconnection.
static AmqpConnection	AmqpConnection.newInstance(AmqpConnection arg)

Methods in io.vertx.reactivex.amqp that return types with arguments of type AmqpConnection

Modifier and Type	Method and Description
Single<AmqpConnection>	AmqpClient.rxConnect() Connects to the AMQP broker or router.

Method parameters in io.vertx.reactivex.amqp with type arguments of type AmqpConnection

Modifier and Type	Method and Description
AmqpClient	AmqpClient.connect(Handler<AsyncResult<AmqpConnection>> connectionHandler) Connects to the AMQP broker or router.