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 Description static io.vertx.lang.rx.TypeArg<RabbitMQMessage>
RabbitMQMessage. __TYPE_ARG
Methods in io.vertx.reactivex.rabbitmq that return RabbitMQMessage Modifier and Type Method 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 Description Future<RabbitMQMessage>
RabbitMQClient. basicGet(String queue, boolean autoAck)
Retrieve a message from a queue using AMQP.Basic.GetPipe<RabbitMQMessage>
RabbitMQConsumer. pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .Single<RabbitMQMessage>
RabbitMQClient. rxBasicGet(String queue, boolean autoAck)
Retrieve a message from a queue using AMQP.Basic.GetFlowable<RabbitMQMessage>
RabbitMQConsumer. toFlowable()
Observable<RabbitMQMessage>
RabbitMQConsumer. toObservable()
Method parameters in io.vertx.reactivex.rabbitmq with type arguments of type RabbitMQMessage Modifier and Type Method Description RabbitMQConsumer
RabbitMQConsumer. handler(Handler<RabbitMQMessage> messageArrived)
Set a message handler.Future<Void>
RabbitMQConsumer. pipeTo(WriteStream<RabbitMQMessage> dst)
Pipe thisReadStream
to theWriteStream
.Completable
RabbitMQConsumer. rxPipeTo(WriteStream<RabbitMQMessage> dst)
Pipe thisReadStream
to theWriteStream
.
-