Uses of Class
io.vertx.reactivex.rabbitmq.RabbitMQMessage

Packages that use RabbitMQMessage

Package	Description
io.vertx.reactivex.rabbitmq

Uses of RabbitMQMessage in io.vertx.reactivex.rabbitmq

Fields in io.vertx.reactivex.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.reactivex.rabbitmq that return RabbitMQMessage

Modifier and Type	Method and Description
static RabbitMQMessage	RabbitMQMessage.newInstance(RabbitMQMessage arg)

Methods in io.vertx.reactivex.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 .
Flowable<RabbitMQMessage>	RabbitMQConsumer.toFlowable()
Observable<RabbitMQMessage>	RabbitMQConsumer.toObservable()

Method parameters in io.vertx.reactivex.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.reactivex.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.
Completable	RabbitMQConsumer.rxPipeTo(WriteStream<RabbitMQMessage> dst) Pipe this ReadStream to the WriteStream.