| 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)Sends an AMQP message and waits for an acknowledgement. | 
| AmqpSender | AmqpSender. sendWithAck(AmqpMessage message,
           Handler<AsyncResult<Void>> acknowledgementHandler)Sends an AMQP message and waits for an acknowledgement. | 
| AmqpSender | AmqpSender. setWriteQueueMaxSize(int maxSize) | 
| 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 © 2023 Eclipse. All rights reserved.