| Package | Description | 
|---|---|
| io.vertx.rxjava.amqp | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<AmqpClient> | 
AmqpClient.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpClient | 
AmqpClient.connect()
Connects to the AMQP broker or router. 
 | 
AmqpClient | 
AmqpClient.connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
Connects to the AMQP broker or router. 
 | 
static AmqpClient | 
AmqpClient.create(AmqpClientOptions options)
Creates a new instance of  
AmqpClient using an internal Vert.x instance (with default configuration) and
 the given AMQP client configuration. | 
static AmqpClient | 
AmqpClient.create(Vertx vertx,
      AmqpClientOptions options)
Creates a new instance of  
AmqpClient with the given Vert.x instance and the given options. | 
AmqpClient | 
AmqpClient.createReceiver(String address)
Creates a receiver used to consume messages from the given address. 
 | 
AmqpClient | 
AmqpClient.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address. 
 | 
AmqpClient | 
AmqpClient.createReceiver(String address,
              AmqpReceiverOptions receiverOptions,
              Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address. 
 | 
AmqpClient | 
AmqpClient.createReceiver(String address,
              Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address. 
 | 
AmqpClient | 
AmqpClient.createSender(String address)
Creates a sender used to send messages to the given address. 
 | 
AmqpClient | 
AmqpClient.createSender(String address,
            AmqpSenderOptions options)
Creates a sender used to send messages to the given address. 
 | 
AmqpClient | 
AmqpClient.createSender(String address,
            AmqpSenderOptions options,
            Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address. 
 | 
AmqpClient | 
AmqpClient.createSender(String address,
            Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address. 
 | 
static AmqpClient | 
AmqpClient.newInstance(AmqpClient arg)  | 
Copyright © 2021 Eclipse. All rights reserved.