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)
Sends a message and 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 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 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. |
EventBus |
EventBus.unregisterCodec(String name)
Unregister a message codec.
|
Copyright © 2021 Eclipse. All rights reserved.