Uses of Class
io.vertx.rxjava3.core.eventbus.EventBus
Packages that use EventBus
-
Uses of EventBus in io.vertx.rxjava3.core
Methods in io.vertx.rxjava3.core that return EventBus -
Uses of EventBus in io.vertx.rxjava3.core.eventbus
Fields in io.vertx.rxjava3.core.eventbus with type parameters of type EventBusModifier and TypeFieldDescriptionstatic final io.vertx.lang.rx.TypeArg<EventBus> EventBus.__TYPE_ARGMethods in io.vertx.rxjava3.core.eventbus that return EventBusModifier and TypeMethodDescription<T> EventBusEventBus.addInboundInterceptor(Handler<DeliveryContext<T>> interceptor) Add an interceptor that will be called whenever a message is received by Vert.x<T> EventBusEventBus.addOutboundInterceptor(Handler<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(EventBus arg) Publish a message.EventBus.publish(String address, Object message, DeliveryOptions options) LikeEventBus.publish(String, Object)but specifyingoptionsthat can be used to configure the delivery.EventBus.registerCodec(MessageCodec codec) Register a message codec.<T> EventBusEventBus.removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor) Remove an interceptor that was added byEventBus.addInboundInterceptor(Handler)<T> EventBusEventBus.removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor) Remove an interceptor that was added byEventBus.addOutboundInterceptor(Handler)Sends a message.EventBus.send(String address, Object message, DeliveryOptions options) LikeEventBus.send(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.