| Package | Description | 
|---|---|
| io.vertx.rxjava3.amqp | 
| Modifier and Type | Field and Description | 
|---|---|
| static io.vertx.lang.rx.TypeArg<AmqpReceiver> | AmqpReceiver. __TYPE_ARG | 
| Modifier and Type | Method and Description | 
|---|---|
| AmqpReceiver | AmqpReceiver. endHandler(Handler<Void> endHandler) | 
| AmqpReceiver | AmqpReceiver. exceptionHandler(Handler<Throwable> handler) | 
| AmqpReceiver | AmqpReceiver. fetch(long amount) | 
| AmqpReceiver | AmqpReceiver. handler(Handler<AmqpMessage> handler) | 
| static AmqpReceiver | AmqpReceiver. newInstance(AmqpReceiver arg) | 
| AmqpReceiver | AmqpReceiver. pause() | 
| AmqpReceiver | AmqpReceiver. resume() | 
| Modifier and Type | Method and Description | 
|---|---|
| Single<AmqpReceiver> | AmqpConnection. createDynamicReceiver()Creates a dynamic receiver. | 
| Single<AmqpReceiver> | AmqpConnection. createReceiver(String address)Creates a receiver used to consume messages from the given address. | 
| Single<AmqpReceiver> | AmqpClient. createReceiver(String address)Creates a receiver used to consume messages from the given address. | 
| Single<AmqpReceiver> | AmqpConnection. createReceiver(String address,
              AmqpReceiverOptions receiverOptions)Creates a receiver used to consumer messages from the given address. | 
| Single<AmqpReceiver> | AmqpClient. createReceiver(String address,
              AmqpReceiverOptions receiverOptions)Creates a receiver used to consumer messages from the given address. | 
| Single<AmqpReceiver> | AmqpConnection. rxCreateDynamicReceiver()Creates a dynamic receiver. | 
| Single<AmqpReceiver> | AmqpConnection. rxCreateReceiver(String address)Creates a receiver used to consume messages from the given address. | 
| Single<AmqpReceiver> | AmqpClient. rxCreateReceiver(String address)Creates a receiver used to consume messages from the given address. | 
| Single<AmqpReceiver> | AmqpConnection. rxCreateReceiver(String address,
                AmqpReceiverOptions receiverOptions)Creates a receiver used to consumer messages from the given address. | 
| Single<AmqpReceiver> | AmqpClient. rxCreateReceiver(String address,
                AmqpReceiverOptions receiverOptions)Creates a receiver used to consumer messages from the given address. | 
Copyright © 2021 Eclipse. All rights reserved.