| Package | Description | 
|---|---|
| io.vertx.core | |
| io.vertx.core.eventbus | |
| io.vertx.reactivex.core.eventbus | |
| io.vertx.rxjava.core.eventbus | |
| io.vertx.serviceproxy | 
| Modifier and Type | Method and Description | 
|---|---|
EventBus | 
Vertx.eventBus()
Get the event bus object. 
 | 
| 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.publish(String address,
       Object message)
Publish a message. 
 | 
EventBus | 
EventBus.publish(String address,
       Object message,
       DeliveryOptions options)
Like  
publish(String, Object) but specifying options that can be used to configure the delivery. | 
EventBus | 
EventBus.registerCodec(MessageCodec codec)
Register a message codec. 
 | 
<T> EventBus | 
EventBus.registerDefaultCodec(Class<T> clazz,
                    MessageCodec<T,?> codec)
Register a default message codec. 
 | 
<T> EventBus | 
EventBus.removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)
Remove an interceptor that was added by  
addInboundInterceptor(Handler) | 
<T> EventBus | 
EventBus.removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)
Remove an interceptor that was added by  
addOutboundInterceptor(Handler) | 
default <T> EventBus | 
EventBus.request(String address,
       Object message,
       DeliveryOptions options,
       Handler<AsyncResult<Message<T>>> replyHandler)
Like  
request(String, Object, Handler) but specifying options that can be used to configure the delivery. | 
default <T> EventBus | 
EventBus.request(String address,
       Object message,
       Handler<AsyncResult<Message<T>>> replyHandler)
Sends a message and 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(String, Object) but specifying options that can be used to configure the delivery. | 
<T> EventBus | 
EventBus.send(String address,
    Object message,
    DeliveryOptions options,
    Handler<AsyncResult<Message<T>>> replyHandler)
Deprecated. 
 
 | 
<T> EventBus | 
EventBus.send(String address,
    Object message,
    Handler<AsyncResult<Message<T>>> replyHandler)
Deprecated. 
 
use  
request(String, Object, Handler) instead | 
EventBus | 
EventBus.unregisterCodec(String name)
Unregister a message codec. 
 | 
EventBus | 
EventBus.unregisterDefaultCodec(Class clazz)
Unregister a default message codec. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
EventBus | 
EventBus.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static EventBus | 
EventBus.newInstance(EventBus arg)  | 
| Constructor and Description | 
|---|
EventBus(EventBus delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
EventBus | 
EventBus.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static EventBus | 
EventBus.newInstance(EventBus arg)  | 
| Constructor and Description | 
|---|
EventBus(EventBus delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
MessageConsumer<JsonObject> | 
ProxyHandler.register(EventBus eventBus,
        String address)
Register the proxy handle on the event bus. 
 | 
MessageConsumer<JsonObject> | 
ProxyHandler.register(EventBus eventBus,
        String address,
        List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors)
Register the proxy handle on the event bus. 
 | 
MessageConsumer<JsonObject> | 
ProxyHandler.registerLocal(EventBus eventBus,
             String address)
Register the local proxy handle on the event bus. 
 | 
MessageConsumer<JsonObject> | 
ProxyHandler.registerLocal(EventBus eventBus,
             String address,
             List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors)
Register the local proxy handle on the event bus. 
 | 
Copyright © 2020 Eclipse. All rights reserved.