## Uses of Class
io.vertx.reactivex.amqp.AmqpMessage

- Packages that use AmqpMessage
  Package | Description
  --- | ---
  io.vertx.reactivex.amqp |

- - ### Uses of AmqpMessage in io.vertx.reactivex.amqp

    Fields in io.vertx.reactivex.amqp with type parameters of type AmqpMessage
    Modifier and Type | Field | Description
    --- | --- | ---
    `static io.vertx.lang.rx.TypeArg<AmqpMessage>` | AmqpMessage.`__TYPE_ARG` |

    Methods in io.vertx.reactivex.amqp that return AmqpMessage
    Modifier and Type | Method | Description
    --- | --- | ---
    `AmqpMessage` | AmqpMessage.`accepted()` | When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message.
    `AmqpMessage` | AmqpMessageBuilder.`build()` |
    `AmqpMessage` | AmqpMessage.`modified​(boolean deliveryFailed, boolean undeliverableHere)` | When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as `modified`.
    `static AmqpMessage` | AmqpMessage.`newInstance​(AmqpMessage arg)` |
    `AmqpMessage` | AmqpMessage.`rejected()` | When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as `rejected`.
    `AmqpMessage` | AmqpMessage.`released()` | When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as `released`.

    Methods in io.vertx.reactivex.amqp that return types with arguments of type AmqpMessage
    Modifier and Type | Method | Description
    --- | --- | ---
    `WriteStream<AmqpMessage>` | AmqpSender.`drainHandler​(Handler<Void> handler)` | Set a drain handler on the stream.
    `Pipe<AmqpMessage>` | AmqpReceiver.`pipe()` | Pause this stream and return a to transfer the elements of this stream to a destination .
    `Flowable<AmqpMessage>` | AmqpReceiver.`toFlowable()` |
    `Observable<AmqpMessage>` | AmqpReceiver.`toObservable()` |
    `WriteStreamObserver<AmqpMessage>` | AmqpSender.`toObserver()` |
    `WriteStreamSubscriber<AmqpMessage>` | AmqpSender.`toSubscriber()` |

    Methods in io.vertx.reactivex.amqp with parameters of type AmqpMessage
    Modifier and Type | Method | Description
    --- | --- | ---
    `static AmqpMessageBuilder` | AmqpMessage.`create​(AmqpMessage existing)` | Creates a builder to create a new `AmqpMessage` copying the metadata from the passed message.
    `Future<Void>` | AmqpSender.`end​(AmqpMessage data)` | Same as `WriteStream.end()` but writes some data to the stream before ending.
    `Completable` | AmqpSender.`rxEnd​(AmqpMessage data)` | Same as `WriteStream.end()` but writes some data to the stream before ending.
    `Completable` | AmqpSender.`rxSendWithAck​(AmqpMessage message)` | Sends an AMQP message and waits for an acknowledgement.
    `Completable` | AmqpSender.`rxWrite​(AmqpMessage data)` | Write some data to the stream.
    `AmqpSender` | AmqpSender.`send​(AmqpMessage message)` | Sends an AMQP message.
    `Future<Void>` | AmqpSender.`sendWithAck​(AmqpMessage message)` | Sends an AMQP message and waits for an acknowledgement.
    `Future<Void>` | AmqpSender.`write​(AmqpMessage data)` | Write some data to the stream.

    Method parameters in io.vertx.reactivex.amqp with type arguments of type AmqpMessage
    Modifier and Type | Method | Description
    --- | --- | ---
    `AmqpReceiver` | AmqpReceiver.`handler​(Handler<AmqpMessage> handler)` |
    `Future<Void>` | AmqpReceiver.`pipeTo​(WriteStream<AmqpMessage> dst)` | Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | AmqpReceiver.`rxPipeTo​(WriteStream<AmqpMessage> dst)` | Pipe this `ReadStream` to the `WriteStream`.