| Package | Description | 
|---|---|
| io.vertx.amqp | |
| io.vertx.reactivex.amqp | |
| io.vertx.rxjava.amqp | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpSender | 
AmqpSender.exceptionHandler(Handler<Throwable> handler)  | 
AmqpSender | 
AmqpSender.send(AmqpMessage message)
Sends an AMQP message. 
 | 
AmqpSender | 
AmqpSender.sendWithAck(AmqpMessage message,
           Handler<AsyncResult<Void>> acknowledgementHandler)
Sends an AMQP message and waits for an acknowledgement. 
 | 
AmqpSender | 
AmqpSender.setWriteQueueMaxSize(int maxSize)  | 
AmqpSender | 
AmqpSender.write(AmqpMessage data)  | 
AmqpSender | 
AmqpSender.write(AmqpMessage data,
     Handler<AsyncResult<Void>> handler)  | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpConnection | 
AmqpConnection.createAnonymousSender(Handler<AsyncResult<AmqpSender>> completionHandler)
Creates an anonymous sender. 
 | 
AmqpConnection | 
AmqpConnection.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,
            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. 
 | 
AmqpClient | 
AmqpClient.createSender(String address,
            Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpSender | 
AmqpSender.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static AmqpSender | 
AmqpSender.newInstance(AmqpSender arg)  | 
| Constructor and Description | 
|---|
AmqpSender(AmqpSender delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpSender | 
AmqpSender.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static AmqpSender | 
AmqpSender.newInstance(AmqpSender arg)  | 
| Constructor and Description | 
|---|
AmqpSender(AmqpSender delegate)  | 
Copyright © 2020 Eclipse. All rights reserved.