Uses of Class
io.vertx.mutiny.core.eventbus.EventBus
Packages that use EventBus
Package
Description
-
Uses of EventBus in io.vertx.mutiny.core
Methods in io.vertx.mutiny.core that return EventBus -
Uses of EventBus in io.vertx.mutiny.core.eventbus
Fields in io.vertx.mutiny.core.eventbus with type parameters of type EventBusMethods in io.vertx.mutiny.core.eventbus that return EventBusModifier and TypeMethodDescription<T> EventBusEventBus.addInboundInterceptor(Consumer<DeliveryContext<T>> interceptor) Add an interceptor that will be called whenever a message is received by Vert.x<T> EventBusEventBus.addOutboundInterceptor(Consumer<DeliveryContext<T>> interceptor) Add an interceptor that will be called whenever a message is sent from Vert.xEventBus.clusterSerializableChecker(Function<String, Boolean> classNamePredicate) Register a predicate to invoke when verifying if an object is forbidden to be encoded/decoded asClusterSerializable.EventBus.codecSelector(Function<Object, String> selector) Set selector to be invoked when the bus has not found any codec for aMessagebody.static EventBusEventBus.newInstance(io.vertx.core.eventbus.EventBus delegate) Creates a new instance of theEventBus.Publish a message.Likepublish(String, Object)but specifyingoptionsthat can be used to configure the delivery.EventBus.registerCodec(io.vertx.core.eventbus.MessageCodec codec) Register a message codec.<T> EventBusEventBus.removeInboundInterceptor(Consumer<DeliveryContext<T>> interceptor) Remove an interceptor that was added by#addInboundInterceptor(Handler)<T> EventBusEventBus.removeOutboundInterceptor(Consumer<DeliveryContext<T>> interceptor) Remove an interceptor that was added by#addOutboundInterceptor(Handler)<T> EventBusEventBus.requestAndForget(String address, Object message) Sends a message and specify areplyHandlerthat will be called if the recipient subsequently replies to the message.<T> EventBusEventBus.requestAndForget(String address, Object message, io.vertx.core.eventbus.DeliveryOptions options) Likerequest(String, Object)but specifyingoptionsthat can be used to configure the delivery.Sends a message.Likesend(String, Object)but specifyingoptionsthat can be used to configure the delivery.EventBus.serializableChecker(Function<String, Boolean> classNamePredicate) Register a predicate to invoke when verifying if an object is allowed to be encoded/decoded asSerializable.EventBus.unregisterCodec(String name) Unregister a message codec. -
Uses of EventBus in io.vertx.mutiny.ext.web.api.service
Methods in io.vertx.mutiny.ext.web.api.service with parameters of type EventBusModifier and TypeMethodDescriptionstatic RouteToEBServiceHandlerBuild a newRouteToEBServiceHandlerstatic RouteToEBServiceHandlerRouteToEBServiceHandler.build(EventBus eventBus, String address, String actionName, io.vertx.core.eventbus.DeliveryOptions deliveryOptions) Build a newRouteToEBServiceHandler