Uses of Class
io.vertx.mutiny.core.eventbus.Message

Packages that use Message

Package	Description
io.vertx.mutiny.core.eventbus

Uses of Message in io.vertx.mutiny.core.eventbus

Fields in io.vertx.mutiny.core.eventbus with type parameters of type Message

Modifier and Type	Field	Description
static final TypeArg<Message>	Message.__TYPE_ARG

Methods in io.vertx.mutiny.core.eventbus that return Message

Modifier and Type	Method	Description
Message<T>	DeliveryContext.message()
static <T> Message<T>	Message.newInstance(io.vertx.core.eventbus.Message arg)
static <T> Message<T>	Message.newInstance(io.vertx.core.eventbus.Message arg, TypeArg<T> __typeArg_T)
<R> Message<R>	Message.replyAndRequestAndAwait(Object message)	Blocking variant of replyAndRequest(Object).
<R> Message<R>	Message.replyAndRequestAndAwait(Object message, io.vertx.core.eventbus.DeliveryOptions options)	Blocking variant of replyAndRequest(Object,DeliveryOptions).
<T> Message<T>	EventBus.requestAndAwait(String address, Object message)	Blocking variant of EventBus.request(String,Object).
<T> Message<T>	EventBus.requestAndAwait(String address, Object message, io.vertx.core.eventbus.DeliveryOptions options)	Blocking variant of EventBus.request(String,Object,DeliveryOptions).

Methods in io.vertx.mutiny.core.eventbus that return types with arguments of type Message

Modifier and Type	Method	Description
Pipe<Message<T>>	MessageConsumer.pipe()
<R> io.smallrye.mutiny.Uni<Message<R>>	Message.replyAndRequest(Object message)	Reply to this message, specifying a replyHandler for the reply - i.e.
<R> io.smallrye.mutiny.Uni<Message<R>>	Message.replyAndRequest(Object message, io.vertx.core.eventbus.DeliveryOptions options)	Like replyAndRequest(java.lang.Object) but specifying options that can be used to configure the delivery.
<T> io.smallrye.mutiny.Uni<Message<T>>	EventBus.request(String address, Object message)	Sends a message and specify a replyHandler that will be called if the recipient subsequently replies to the message.
<T> io.smallrye.mutiny.Uni<Message<T>>	EventBus.request(String address, Object message, io.vertx.core.eventbus.DeliveryOptions options)	Like EventBus.request(java.lang.String, java.lang.Object) but specifying options that can be used to configure the delivery.
Iterable<Message<T>>	MessageConsumer.toBlockingIterable()
Stream<Message<T>>	MessageConsumer.toBlockingStream()
io.smallrye.mutiny.Multi<Message<T>>	MessageConsumer.toMulti()

Method parameters in io.vertx.mutiny.core.eventbus with type arguments of type Message

Modifier and Type	Method	Description
<T> MessageConsumer<T>	EventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions options, Consumer<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.consumer(String address, Consumer<Message<T>> handler)
MessageConsumer<T>	MessageConsumer.handler(Consumer<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Consumer<Message<T>> handler)
io.smallrye.mutiny.Uni<Void>	MessageConsumer.pipeTo(WriteStream<Message<T>> dst)	Pipe this ReadStream to the WriteStream.
Void	MessageConsumer.pipeToAndAwait(WriteStream<Message<T>> dst)	Blocking variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream).
void	MessageConsumer.pipeToAndForget(WriteStream<Message<T>> dst)	Variant of ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream) that ignores the result of the operation.