| Package | Description | 
|---|---|
| io.vertx.rxjava.amqp | 
| Modifier and Type | Field and Description | 
|---|---|
| static io.vertx.lang.rx.TypeArg<AmqpConnection> | AmqpConnection. __TYPE_ARG | 
| 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) | 
| Modifier and Type | Method and Description | 
|---|---|
| Single<AmqpConnection> | AmqpClient. rxConnect()Connects to the AMQP broker or router. | 
| Modifier and Type | Method and Description | 
|---|---|
| AmqpClient | AmqpClient. connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)Connects to the AMQP broker or router. | 
Copyright © 2023 Eclipse. All rights reserved.