| Package | Description | 
|---|---|
| io.vertx.rxjava3.amqp | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<AmqpConnection> | 
AmqpConnection.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpConnection | 
AmqpSender.connection()
Gets the connection having created the sender. 
 | 
AmqpConnection | 
AmqpReceiver.connection()
Gets the connection having created the receiver. 
 | 
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.connect()
Connects to the AMQP broker or router. 
 | 
Single<AmqpConnection> | 
AmqpClient.rxConnect()
Connects to the AMQP broker or router. 
 | 
Copyright © 2023 Eclipse. All rights reserved.