## Uses of Class
io.vertx.reactivex.core.eventbus.EventBus

- 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 and 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 and 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 and 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(java.util.function.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(java.util.function.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>>)`
    `<T> EventBus` | EventBus.`request(String address, Object message)` Sends a message and specify a `replyHandler` that will be called if the recipient subsequently replies to the message.
    `<T> EventBus` | EventBus.`request(String address, Object message, DeliveryOptions options)` Like `request(java.lang.String, java.lang.Object, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.core.eventbus.Message<T>>>)` but specifying `options` that can be used to configure the delivery.
    `<T> EventBus` | EventBus.`request(String address, Object message, DeliveryOptions options, Handler<AsyncResult<Message<T>>> replyHandler)` Like `request(java.lang.String, java.lang.Object, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.reactivex.core.eventbus.Message<T>>>)` but specifying `options` that can be used to configure the delivery.
    `<T> EventBus` | EventBus.`request(String address, Object message, Handler<AsyncResult<Message<T>>> replyHandler)` Sends a message and specify a `replyHandler` that will be called if the recipient subsequently replies to the message.
    `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(java.util.function.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.

Copyright © 2025 Eclipse. All rights reserved.