Uses of Interface
io.vertx.core.eventbus.Message

Packages that use Message

Package	Description
io.vertx.core.eventbus
io.vertx.core.spi.cluster
io.vertx.core.spi.metrics
io.vertx.ext.unit.collect
io.vertx.reactivex.core.eventbus
io.vertx.rxjava.core.eventbus
io.vertx.rxjava3.core.eventbus
io.vertx.serviceproxy

Uses of Message in io.vertx.core.eventbus

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

Modifier and Type	Method and Description
Message<T>	DeliveryContext.message()

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

Modifier and Type	Method and Description
default <R> Future<Message<R>>	Message.replyAndRequest(Object message) Like replyAndRequest(Object, Handler) but returns a Future of the asynchronous result
<R> Future<Message<R>>	Message.replyAndRequest(Object message, DeliveryOptions options) Like replyAndRequest(Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result
default <T> Future<Message<T>>	EventBus.request(String address, Object message) Like EventBus.request(String, Object, Handler) but returns a Future of the asynchronous result
<T> Future<Message<T>>	EventBus.request(String address, Object message, DeliveryOptions options) Like EventBus.request(String, Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result

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

Modifier and Type	Method and Description
<T> MessageConsumer<T>	EventBus.consumer(String address, Handler<Message<T>> handler) Create a consumer and register it against the specified address.
MessageConsumer<T>	MessageConsumer.handler(Handler<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Handler<Message<T>> handler) Like EventBus.consumer(String, Handler) but the address won't be propagated across the cluster.
default <R> void	Message.replyAndRequest(Object message, DeliveryOptions options, Handler<AsyncResult<Message<R>>> replyHandler) Like replyAndRequest(Object, Handler) but specifying options that can be used to configure the delivery.
default <R> void	Message.replyAndRequest(Object message, Handler<AsyncResult<Message<R>>> replyHandler) Reply to this message, specifying a replyHandler for the reply - i.e.
default <T> EventBus	EventBus.request(String address, Object message, DeliveryOptions options, Handler<AsyncResult<Message<T>>> replyHandler) Like EventBus.request(String, Object, Handler) but specifying options that can be used to configure the delivery.
default <T> EventBus	EventBus.request(String address, Object message, Handler<AsyncResult<Message<T>>> replyHandler) Sends a message and specify a replyHandler that will be called if the recipient subsequently replies to the message.

Uses of Message in io.vertx.core.spi.cluster

Methods in io.vertx.core.spi.cluster with parameters of type Message

Modifier and Type	Method and Description
void	NodeSelector.selectForPublish(Message<?> message, Promise<Iterable<String>> promise) Select a node for publishing the given message.
void	NodeSelector.selectForSend(Message<?> message, Promise<String> promise) Select a node for sending the given message.

Uses of Message in io.vertx.core.spi.metrics

Methods in io.vertx.core.spi.metrics with parameters of type Message

Modifier and Type	Method and Description
default void	EventBusMetrics.discardMessage(H handler, boolean local, Message<?> msg) Discard a message.

Uses of Message in io.vertx.ext.unit.collect

Methods in io.vertx.ext.unit.collect that return types with arguments of type Message

Modifier and Type	Method and Description
Handler<Message<JsonObject>>	EventBusCollector.asMessageHandler()

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

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

Modifier and Type	Method and Description
Message	Message.getDelegate()

Methods in io.vertx.reactivex.core.eventbus with parameters of type Message

Modifier and Type	Method and Description
static <T> Message<T>	Message.newInstance(Message arg)
static <T> Message<T>	Message.newInstance(Message arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.vertx.reactivex.core.eventbus with parameters of type Message

Constructor and Description
Message(Message delegate)

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

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

Modifier and Type	Method and Description
Message	Message.getDelegate()

Methods in io.vertx.rxjava.core.eventbus with parameters of type Message

Modifier and Type	Method and Description
static <T> Message<T>	Message.newInstance(Message arg)
static <T> Message<T>	Message.newInstance(Message arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.vertx.rxjava.core.eventbus with parameters of type Message

Constructor and Description
Message(Message delegate)

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

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

Modifier and Type	Method and Description
Message	Message.getDelegate()

Methods in io.vertx.rxjava3.core.eventbus with parameters of type Message

Modifier and Type	Method and Description
static <T> Message<T>	Message.newInstance(Message arg)
static <T> Message<T>	Message.newInstance(Message arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.vertx.rxjava3.core.eventbus with parameters of type Message

Constructor and Description
Message(Message delegate)

Uses of Message in io.vertx.serviceproxy

Methods in io.vertx.serviceproxy that return types with arguments of type Message

Modifier and Type	Method and Description
Future<Message<JsonObject>>	ServiceJWTInterceptor.apply(Message<JsonObject> msg) Deprecated.
Future<Message<JsonObject>>	ServiceAuthInterceptor.apply(Message<JsonObject> msg)

Methods in io.vertx.serviceproxy with parameters of type Message

Modifier and Type	Method and Description
Future<Message<JsonObject>>	ServiceJWTInterceptor.apply(Message<JsonObject> msg) Deprecated.
Future<Message<JsonObject>>	ServiceAuthInterceptor.apply(Message<JsonObject> msg)
static <T> Handler<AsyncResult<T>>	HelperUtils.createHandler(Message msg, boolean includeDebugInfo)
static Handler<AsyncResult<List<Character>>>	HelperUtils.createListCharHandler(Message msg, boolean includeDebugInfo)
static <T> Handler<AsyncResult<List<T>>>	HelperUtils.createListHandler(Message msg, boolean includeDebugInfo)
static Handler<AsyncResult<Map<String,Character>>>	HelperUtils.createMapCharHandler(Message msg, boolean includeDebugInfo)
static <T> Handler<AsyncResult<Map<String,T>>>	HelperUtils.createMapHandler(Message msg, boolean includeDebugInfo)
static Handler<AsyncResult<Set<Character>>>	HelperUtils.createSetCharHandler(Message msg, boolean includeDebugInfo)
static <T> Handler<AsyncResult<Set<T>>>	HelperUtils.createSetHandler(Message msg, boolean includeDebugInfo)
static void	HelperUtils.manageFailure(Message msg, Throwable cause, boolean includeDebugInfo)

Method parameters in io.vertx.serviceproxy with type arguments of type Message

Modifier and Type	Method and Description
ServiceBinder	ServiceBinder.addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
ServiceBinder	ServiceBinder.addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
MessageConsumer<JsonObject>	ProxyHandler.register(EventBus eventBus, String address, List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors) Register the proxy handle on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.register(EventBus eventBus, String address, List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors) Register the proxy handle on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.registerLocal(EventBus eventBus, String address, List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors) Register the local proxy handle on the event bus.
MessageConsumer<JsonObject>	ProxyHandler.registerLocal(EventBus eventBus, String address, List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors) Register the local proxy handle on the event bus.