Uses of Class io.vertx.reactivex.core.eventbus.EventBus (Vert.x Stack - Docs 5.0.5 API)

Packages that use EventBus
Package Description

io.vertx.reactivex.core

io.vertx.reactivex.core.eventbus

Uses of EventBus in io.vertx.reactivex.core

Methods in io.vertx.reactivex.core that return EventBus
Modifier and Type Method Description

EventBus Vertx.eventBus()
Get the event bus object.

Uses of EventBus in io.vertx.reactivex.core.eventbus

Fields in io.vertx.reactivex.core.eventbus with type parameters of type EventBus
Modifier and Type	Field	Description
`static io.vertx.lang.rx.TypeArg<EventBus>`	EventBus.`__TYPE_ARG`

Methods in io.vertx.reactivex.core.eventbus that return EventBus
Modifier and Type	Method	Description
`<T> EventBus`	EventBus.`addInboundInterceptor(Handler<DeliveryContext<T>> interceptor)`	Add an interceptor that will be called whenever a message is received by Vert.x
`<T> EventBus`	EventBus.`addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)`	Add an interceptor that will be called whenever a message is sent from Vert.x
`EventBus`	EventBus.`clusterSerializableChecker(Function<String,Boolean> classNamePredicate)`	Register a predicate to invoke when verifying if an object is forbidden to be encoded/decoded as `ClusterSerializable`.
`EventBus`	EventBus.`codecSelector(Function<Object,String> selector)`	Set selector to be invoked when the bus has not found any codec for a `Message` body.
`static EventBus`	EventBus.`newInstance(EventBus arg)`
`EventBus`	EventBus.`publish(String address, Object message)`	Publish a message.
`EventBus`	EventBus.`publish(String address, Object message, DeliveryOptions options)`	Like `publish(java.lang.String, java.lang.Object)` but specifying `options` that can be used to configure the delivery.
`EventBus`	EventBus.`registerCodec(MessageCodec codec)`	Register a message codec.
`<T> EventBus`	EventBus.`removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)`	Remove an interceptor that was added by `addInboundInterceptor(io.vertx.core.Handler<io.vertx.reactivex.core.eventbus.DeliveryContext<T>>)`
`<T> EventBus`	EventBus.`removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)`	Remove an interceptor that was added by `addOutboundInterceptor(io.vertx.core.Handler<io.vertx.reactivex.core.eventbus.DeliveryContext<T>>)`
`EventBus`	EventBus.`send(String address, Object message)`	Sends a message.
`EventBus`	EventBus.`send(String address, Object message, DeliveryOptions options)`	Like `send(java.lang.String, java.lang.Object)` but specifying `options` that can be used to configure the delivery.
`EventBus`	EventBus.`serializableChecker(Function<String,Boolean> classNamePredicate)`	Register a predicate to invoke when verifying if an object is allowed to be encoded/decoded as `Serializable`.
`EventBus`	EventBus.`unregisterCodec(String name)`	Unregister a message codec.