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	Description
static io.vertx.lang.rx.TypeArg<AmqpMessage>	AmqpMessage.__TYPE_ARG

Methods in io.vertx.reactivex.amqp that return AmqpMessage

Modifier and Type	Method	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	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()
WriteStreamObserver<AmqpMessage>	AmqpSender.toObserver()
WriteStreamSubscriber<AmqpMessage>	AmqpSender.toSubscriber()

Methods in io.vertx.reactivex.amqp with parameters of type AmqpMessage

Modifier and Type	Method	Description
static AmqpMessageBuilder	AmqpMessage.create(AmqpMessage existing)	Creates a builder to create a new AmqpMessage copying the metadata from the passed message.
Future<Void>	AmqpSender.end(AmqpMessage data)	Same as WriteStream.end() but writes some data to the stream before ending.
Completable	AmqpSender.rxEnd(AmqpMessage data)	Same as WriteStream.end() but writes some data to the stream before ending.
Completable	AmqpSender.rxSendWithAck(AmqpMessage message)	Sends an AMQP message and waits for an acknowledgement.
Completable	AmqpSender.rxWrite(AmqpMessage data)	Write some data to the stream.
AmqpSender	AmqpSender.send(AmqpMessage message)	Sends an AMQP message.
Future<Void>	AmqpSender.sendWithAck(AmqpMessage message)	Sends an AMQP message and waits for an acknowledgement.
Future<Void>	AmqpSender.write(AmqpMessage data)	Write some data to the stream.

Method parameters in io.vertx.reactivex.amqp with type arguments of type AmqpMessage

Modifier and Type	Method	Description
AmqpReceiver	AmqpReceiver.handler(Handler<AmqpMessage> handler)
Future<Void>	AmqpReceiver.pipeTo(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.
Completable	AmqpReceiver.rxPipeTo(WriteStream<AmqpMessage> dst)	Pipe this ReadStream to the WriteStream.