| Package | Description | 
|---|---|
| io.vertx.rxjava.amqp | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<AmqpSender> | 
AmqpSender.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
AmqpSender | 
AmqpSender.exceptionHandler(Handler<Throwable> handler)  | 
static AmqpSender | 
AmqpSender.newInstance(AmqpSender arg)  | 
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 | 
|---|---|
Single<AmqpSender> | 
AmqpConnection.rxCreateAnonymousSender()
Creates an anonymous sender. 
 | 
Single<AmqpSender> | 
AmqpConnection.rxCreateSender(String address)
Creates a sender used to send messages to the given address. 
 | 
Single<AmqpSender> | 
AmqpClient.rxCreateSender(String address)
Creates a sender used to send messages to the given address. 
 | 
Single<AmqpSender> | 
AmqpConnection.rxCreateSender(String address,
              AmqpSenderOptions options)
Creates a sender used to send messages to the given address. 
 | 
Single<AmqpSender> | 
AmqpClient.rxCreateSender(String address,
              AmqpSenderOptions options)
Creates a sender used to send messages to the given address. 
 | 
| 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. 
 | 
Copyright © 2020 Eclipse. All rights reserved.