Uses of Class
io.vertx.rxjava.amqp.AmqpMessage
-
Packages that use AmqpMessage Package Description io.vertx.rxjava.amqp -
-
Uses of AmqpMessage in io.vertx.rxjava.amqp
Fields in io.vertx.rxjava.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.rxjava.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 asmodified
.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 asrejected
.AmqpMessage
AmqpMessage. released()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message asreleased
.Methods in io.vertx.rxjava.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 .Observable<AmqpMessage>
AmqpReceiver. toObservable()
WriteStreamSubscriber<AmqpMessage>
AmqpSender. toSubscriber()
Methods in io.vertx.rxjava.amqp with parameters of type AmqpMessage Modifier and Type Method Description static AmqpMessageBuilder
AmqpMessage. create(AmqpMessage existing)
Creates a builder to create a newAmqpMessage
copying the metadata from the passed message.Future<Void>
AmqpSender. end(AmqpMessage data)
Same asWriteStream.end()
but writes some data to the stream before ending.Single<Void>
AmqpSender. rxEnd(AmqpMessage data)
Same asWriteStream.end()
but writes some data to the stream before ending.Single<Void>
AmqpSender. rxSendWithAck(AmqpMessage message)
Sends an AMQP message and waits for an acknowledgement.Single<Void>
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.rxjava.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 thisReadStream
to theWriteStream
.Single<Void>
AmqpReceiver. rxPipeTo(WriteStream<AmqpMessage> dst)
Pipe thisReadStream
to theWriteStream
.
-