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 deliveryFailed, boolean undeliverableHere) 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()

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.