Uses of Class
io.vertx.mutiny.amqp.AmqpMessage
-
Packages that use AmqpMessage Package Description io.vertx.mutiny.amqp -
-
Uses of AmqpMessage in io.vertx.mutiny.amqp
Fields in io.vertx.mutiny.amqp with type parameters of type AmqpMessage Modifier and Type Field Description static TypeArg<AmqpMessage>
AmqpMessage. __TYPE_ARG
Methods in io.vertx.mutiny.amqp that return AmqpMessage Modifier and Type Method Description AmqpMessage
AmqpMessage. accepted()
AmqpMessage
AmqpMessageBuilder. build()
AmqpMessage
AmqpMessage. modified(boolean deliveryFailed, boolean undeliverableHere)
static AmqpMessage
AmqpMessage. newInstance(io.vertx.amqp.AmqpMessage arg)
AmqpMessage
AmqpMessage. rejected()
AmqpMessage
AmqpMessage. released()
Methods in io.vertx.mutiny.amqp that return types with arguments of type AmqpMessage Modifier and Type Method Description WriteStream<AmqpMessage>
AmqpSender. drainHandler(Runnable arg0)
Pipe<AmqpMessage>
AmqpReceiver. pipe()
Iterable<AmqpMessage>
AmqpReceiver. toBlockingIterable()
Stream<AmqpMessage>
AmqpReceiver. toBlockingStream()
io.smallrye.mutiny.Multi<AmqpMessage>
AmqpReceiver. toMulti()
WriteStreamSubscriber<AmqpMessage>
AmqpSender. toSubscriber()
Methods in io.vertx.mutiny.amqp with parameters of type AmqpMessage Modifier and Type Method Description static AmqpMessageBuilder
AmqpMessage. create(AmqpMessage existing)
io.smallrye.mutiny.Uni<Void>
AmqpSender. end(AmqpMessage data)
Void
AmqpSender. endAndAwait(AmqpMessage data)
void
AmqpSender. endAndForget(AmqpMessage data)
AmqpSender
AmqpSender. send(AmqpMessage message)
io.smallrye.mutiny.Uni<Void>
AmqpSender. sendWithAck(AmqpMessage message)
Sends an AMQP message and waits for an acknowledgement.Void
AmqpSender. sendWithAckAndAwait(AmqpMessage message)
Blocking variant ofAmqpSender.sendWithAck(io.vertx.mutiny.amqp.AmqpMessage)
.AmqpSender
AmqpSender. sendWithAckAndForget(AmqpMessage message)
Variant ofAmqpSender.sendWithAck(io.vertx.mutiny.amqp.AmqpMessage)
that ignores the result of the operation.io.smallrye.mutiny.Uni<Void>
AmqpSender. write(AmqpMessage arg0)
Void
AmqpSender. writeAndAwait(AmqpMessage arg0)
void
AmqpSender. writeAndForget(AmqpMessage arg0)
Method parameters in io.vertx.mutiny.amqp with type arguments of type AmqpMessage Modifier and Type Method Description AmqpReceiver
AmqpReceiver. handler(Consumer<AmqpMessage> handler)
io.smallrye.mutiny.Uni<Void>
AmqpReceiver. pipeTo(WriteStream<AmqpMessage> dst)
Void
AmqpReceiver. pipeToAndAwait(WriteStream<AmqpMessage> dst)
void
AmqpReceiver. pipeToAndForget(WriteStream<AmqpMessage> dst)
-