<T> EventBus |
EventBus.addInboundInterceptor(io.vertx.core.Handler<DeliveryContext<T>> interceptor) |
Add an interceptor that will be called whenever a message is received by Vert.x
|
<T> EventBus |
EventBus.addOutboundInterceptor(io.vertx.core.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(io.vertx.core.eventbus.EventBus arg) |
|
EventBus |
EventBus.publish(String address,
Object message) |
Publish a message.
|
EventBus |
EventBus.publish(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options) |
|
EventBus |
EventBus.registerCodec(io.vertx.core.eventbus.MessageCodec codec) |
Register a message codec.
|
<T> EventBus |
EventBus.removeInboundInterceptor(io.vertx.core.Handler<DeliveryContext<T>> interceptor) |
|
<T> EventBus |
EventBus.removeOutboundInterceptor(io.vertx.core.Handler<DeliveryContext<T>> interceptor) |
|
<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,
io.vertx.core.eventbus.DeliveryOptions options) |
|
<T> EventBus |
EventBus.request(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<T>>> replyHandler) |
|
<T> EventBus |
EventBus.request(String address,
Object message,
io.vertx.core.Handler<io.vertx.core.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,
io.vertx.core.eventbus.DeliveryOptions options) |
|
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.
|