Uses of Interface
io.vertx.core.eventbus.Message
Packages that use Message
Package
Description
-
Uses of Message in io.vertx.core.eventbus
Subinterfaces with type arguments of type Message in io.vertx.core.eventbusModifier and TypeInterfaceDescriptioninterfaceAn event bus consumer object representing a stream of message to anEventBusaddress that can be read from.Methods in io.vertx.core.eventbus that return MessageMethods in io.vertx.core.eventbus that return types with arguments of type MessageModifier and TypeMethodDescriptionMessage.replyAndRequest(Object message) Reply to this message, specifying areplyHandlerfor the reply - i.e. to receive the reply to the reply.Message.replyAndRequest(Object message, DeliveryOptions options) LikeMessage.replyAndRequest(Object)but specifyingoptionsthat can be used to configure the delivery.Sends a message and specify areplyHandlerthat will be called if the recipient subsequently replies to the message.EventBus.request(String address, Object message, DeliveryOptions options) LikeEventBus.request(String, Object)but specifyingoptionsthat can be used to configure the delivery.Method parameters in io.vertx.core.eventbus with type arguments of type MessageModifier and TypeMethodDescription<T> MessageConsumer<T> EventBus.consumer(MessageConsumerOptions options, Handler<Message<T>> handler) Create a consumer and register it against the specified options address.<T> MessageConsumer<T> Create a consumer and register it against the specified address.<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 MessageModifier and TypeMethodDescriptiondefault voidEventBusMetrics.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 -
Uses of Message in io.vertx.reactivex.core.eventbus
Methods in io.vertx.reactivex.core.eventbus that return MessageMethods in io.vertx.reactivex.core.eventbus with parameters of type MessageModifier and TypeMethodDescriptionstatic <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 -
Uses of Message in io.vertx.rxjava3.core.eventbus
Methods in io.vertx.rxjava3.core.eventbus that return MessageMethods in io.vertx.rxjava3.core.eventbus with parameters of type MessageModifier and TypeMethodDescriptionstatic <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 -
Uses of Message in io.vertx.serviceproxy
Classes in io.vertx.serviceproxy that implement interfaces with type arguments of type MessageMethods in io.vertx.serviceproxy that return types with arguments of type MessageModifier and TypeMethodDescriptionServiceInterceptor.intercept(Vertx vertx, Map<String, Object> interceptorContext, Message<JsonObject> body) Perform the interceptor handlingMethods in io.vertx.serviceproxy with parameters of type MessageModifier and TypeMethodDescriptionstatic <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) ServiceInterceptor.intercept(Vertx vertx, Map<String, Object> interceptorContext, Message<JsonObject> body) Perform the interceptor handlingstatic voidHelperUtils.manageFailure(Message msg, Throwable cause, boolean includeDebugInfo)