## 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 and Description
    --- | ---
    `static io.vertx.lang.rx.TypeArg<AmqpMessage>` | AmqpMessage.`__TYPE_ARG`

    Methods in io.vertx.reactivex.amqp that return AmqpMessage
    Modifier and Type | Method and 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 didItFail, boolean wasItDeliveredHere)` 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 and 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()`
    `io.vertx.reactivex.WriteStreamObserver<AmqpMessage>` | AmqpSender.`toObserver()`
    `io.vertx.reactivex.WriteStreamSubscriber<AmqpMessage>` | AmqpSender.`toSubscriber()`

    Methods in io.vertx.reactivex.amqp with parameters of type AmqpMessage
    Modifier and Type | Method and Description
    --- | ---
    `static AmqpMessageBuilder` | AmqpMessage.`create(AmqpMessage existing)` Creates a builder to create a new `AmqpMessage` copying the metadata from the passed message.
    `void` | AmqpSender.`end(AmqpMessage data)` Same as `WriteStream.end()` but writes some data to the stream before ending.
    `void` | AmqpSender.`end(AmqpMessage data, Handler<AsyncResult<Void>> handler)` Same as but with an `handler` called when the operation completes
    `Completable` | AmqpSender.`rxEnd(AmqpMessage data)` Same as but with an `handler` called when the operation completes
    `Completable` | AmqpSender.`rxSendWithAck(AmqpMessage message)` Sends an AMQP message and waits for an acknowledgement.
    `Completable` | AmqpSender.`rxWrite(AmqpMessage data)`
    `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.`write(AmqpMessage data)`
    `AmqpSender` | AmqpSender.`write(AmqpMessage data, Handler<AsyncResult<Void>> handler)`

    Method parameters in io.vertx.reactivex.amqp with type arguments of type AmqpMessage
    Modifier and Type | Method and Description
    --- | ---
    `AmqpReceiver` | AmqpReceiver.`handler(Handler<AmqpMessage> handler)`
    `void` | AmqpReceiver.`pipeTo(WriteStream<AmqpMessage> dst)` Like `ReadStream.pipeTo(io.vertx.reactivex.core.streams.WriteStream<T>)` but with no completion handler.
    `void` | AmqpReceiver.`pipeTo(WriteStream<AmqpMessage> dst, Handler<AsyncResult<Void>> handler)` Pipe this `ReadStream` to the `WriteStream`.
    `Completable` | AmqpReceiver.`rxPipeTo(WriteStream<AmqpMessage> dst)` Pipe this `ReadStream` to the `WriteStream`.

Copyright © 2020 Eclipse. All rights reserved.