Package | Description |
---|---|
io.vertx.reactivex.rabbitmq |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<RabbitMQMessage> |
RabbitMQMessage.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static RabbitMQMessage |
RabbitMQMessage.newInstance(RabbitMQMessage arg) |
Modifier and Type | Method and Description |
---|---|
Pipe<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.Get
|
Flowable<RabbitMQMessage> |
RabbitMQConsumer.toFlowable() |
Observable<RabbitMQMessage> |
RabbitMQConsumer.toObservable() |
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.basicGet(String queue,
boolean autoAck,
Handler<AsyncResult<RabbitMQMessage>> resultHandler)
Retrieve a message from a queue using AMQP.Basic.Get
|
RabbitMQConsumer |
RabbitMQConsumer.handler(Handler<RabbitMQMessage> messageArrived)
Set a message handler.
|
void |
RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst)
Pipe this
ReadStream to the WriteStream . |
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 . |
Copyright © 2021 Eclipse. All rights reserved.