| Package | Description | 
|---|---|
| io.vertx.rxjava.core | |
| io.vertx.rxjava.core.eventbus | 
| Modifier and Type | Method and Description | 
|---|---|
EventBus | 
Vertx.eventBus()
Get the event bus object. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<EventBus> | 
EventBus.__TYPE_ARG  | 
| 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 
 | 
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  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.rxjava.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.rxjava.core.eventbus.DeliveryContext<T>>) | 
<T> EventBus | 
EventBus.request(String address,
       Object message,
       DeliveryOptions options,
       Handler<AsyncResult<Message<T>>> replyHandler)
Like  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 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  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.  
 | 
EventBus | 
EventBus.unregisterCodec(String name)
Unregister a message codec. 
 | 
Copyright © 2020 Eclipse. All rights reserved.