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

Packages that use Message

Package	Description
io.vertx.core.eventbus
io.vertx.core.spi.metrics
io.vertx.ext.unit.collect
io.vertx.reactivex.core.eventbus
io.vertx.rxjava.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()

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.
<R> void	Message.reply(Object message, DeliveryOptions options, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated. use replyAndRequest(Object, DeliveryOptions, Handler)
<R> void	Message.reply(Object message, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated. use replyAndRequest(Object, Handler)
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 and specify a replyHandler that will be called if the recipient subsequently replies to the message.
<T> EventBus	EventBus.send(String address, Object message, DeliveryOptions options, Handler<AsyncResult<Message<T>>> replyHandler) Deprecated. use EventBus.request(String, Object, DeliveryOptions, Handler) instead
<T> EventBus	EventBus.send(String address, Object message, Handler<AsyncResult<Message<T>>> replyHandler) Deprecated. use EventBus.request(String, Object, Handler) instead
<R> MessageProducer<T>	MessageProducer.send(T message, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated. instead use EventBus.request(String, Object, Handler)

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.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)

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

Modifier and Type	Method and Description
Future<Message<JsonObject>>	ServiceJWTInterceptor.apply(Message<JsonObject> msg)
static <T> Handler<AsyncResult<T>>	HelperUtils.createHandler(Message msg)
static Handler<AsyncResult<List<Character>>>	HelperUtils.createListCharHandler(Message msg)
static <T> Handler<AsyncResult<List<T>>>	HelperUtils.createListHandler(Message msg)
static Handler<AsyncResult<Set<Character>>>	HelperUtils.createSetCharHandler(Message msg)
static <T> Handler<AsyncResult<Set<T>>>	HelperUtils.createSetHandler(Message msg)

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.