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.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 Description Message<T>
DeliveryContext. message()
Methods in io.vertx.core.eventbus that return types with arguments of type Message Modifier and Type Method Description default <R> Future<Message<R>>
Message. replyAndRequest(Object message)
Reply to this message, specifying areplyHandler
for the reply - i.e.<R> Future<Message<R>>
Message. replyAndRequest(Object message, DeliveryOptions options)
LikereplyAndRequest(Object)
but specifyingoptions
that can be used to configure the delivery.default <T> Future<Message<T>>
EventBus. request(String address, Object message)
Sends a message and specify areplyHandler
that will be called if the recipient subsequently replies to the message.<T> Future<Message<T>>
EventBus. request(String address, Object message, DeliveryOptions options)
LikeEventBus.request(String, Object)
but specifyingoptions
that can be used to configure the delivery.Method parameters in io.vertx.core.eventbus with type arguments of type Message Modifier and Type Method 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)
LikeEventBus.consumer(String, Handler)
but the address won't be propagated across the cluster. -
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 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 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 Description Message
Message. getDelegate()
Methods in io.vertx.reactivex.core.eventbus with parameters of type Message Modifier and Type Method 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 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 Description Message
Message. getDelegate()
Methods in io.vertx.rxjava3.core.eventbus with parameters of type Message Modifier and Type Method 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 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 Description Future<Message<JsonObject>>
ServiceAuthInterceptor. apply(Message<JsonObject> msg)
Deprecated.Future<Message<JsonObject>>
ServiceInterceptor. intercept(Vertx vertx, Map<String,Object> interceptorContext, Message<JsonObject> body)
Perform the interceptor handlingMethods in io.vertx.serviceproxy with parameters of type Message Modifier and Type Method Description Future<Message<JsonObject>>
ServiceAuthInterceptor. apply(Message<JsonObject> msg)
Deprecated.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)
Future<Message<JsonObject>>
ServiceInterceptor. intercept(Vertx vertx, Map<String,Object> interceptorContext, Message<JsonObject> body)
Perform the interceptor handlingstatic 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 Description ServiceBinder
ServiceBinder. addInterceptor(String action, java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.ServiceBinder
ServiceBinder. addInterceptor(String action, java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.ServiceBinder
ServiceBinder. addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.ServiceBinder
ServiceBinder. addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.
-