## Uses of Class
io.vertx.rxjava.rabbitmq.RabbitMQMessage

- Packages that use RabbitMQMessage
  Package | Description
  --- | ---
  io.vertx.rxjava.rabbitmq |

- - ### Uses of RabbitMQMessage in io.vertx.rxjava.rabbitmq

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

    Methods in io.vertx.rxjava.rabbitmq that return RabbitMQMessage
    Modifier and Type | Method and Description
    --- | ---
    `static RabbitMQMessage` | RabbitMQMessage.`newInstance(RabbitMQMessage arg)`

    Methods in io.vertx.rxjava.rabbitmq that return types with arguments of type RabbitMQMessage
    Modifier and Type | Method and Description
    --- | ---
    `ReadStream<RabbitMQMessage>` | RabbitMQConsumer.`fetch(long amount)` Fetch the specified `amount` of elements.
    `Pipe<RabbitMQMessage>` | RabbitMQConsumer.`pipe()` Pause this stream and return a to transfer the elements of this stream to a destination .
    `Observable<RabbitMQMessage>` | RabbitMQConsumer.`toObservable()`

    Method parameters in io.vertx.rxjava.rabbitmq with type arguments of type RabbitMQMessage
    Modifier and Type | Method and Description
    --- | ---
    `RabbitMQConsumer` | RabbitMQConsumer.`handler(Handler<RabbitMQMessage> messageArrived)` Set a message handler.
    `void` | RabbitMQConsumer.`pipeTo(WriteStream<RabbitMQMessage> dst)` Like `ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>)` but with no completion handler.
    `void` | RabbitMQConsumer.`pipeTo(WriteStream<RabbitMQMessage> dst, Handler<AsyncResult<Void>> handler)` Pipe this `ReadStream` to the `WriteStream`.
    `Observable<Void>` | RabbitMQConsumer.`pipeToObservable(WriteStream<RabbitMQMessage> dst)` Deprecated. use `RabbitMQConsumer.rxPipeTo(io.vertx.rxjava.core.streams.WriteStream<io.vertx.rxjava.rabbitmq.RabbitMQMessage>)` instead
    `Single<Void>` | RabbitMQConsumer.`rxPipeTo(WriteStream<RabbitMQMessage> dst)` Pipe this `ReadStream` to the `WriteStream`.

Copyright © 2021 Eclipse. All rights reserved.