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.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. |
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 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. |
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.
|
EventBus |
EventBus.unregisterDefaultCodec(Class clazz)
Unregister a default message codec.
|
Modifier and Type | Method and Description |
---|---|
static RouteToEBServiceHandler |
RouteToEBServiceHandler.build(EventBus eventBus,
String address,
String actionName)
Build a new
RouteToEBServiceHandler |
static RouteToEBServiceHandler |
RouteToEBServiceHandler.build(EventBus eventBus,
String address,
String actionName,
DeliveryOptions deliveryOptions)
Build a new
RouteToEBServiceHandler |
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 |
---|---|
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.registerLocal(EventBus eventBus,
String address)
Register the local proxy handle on the event bus.
|
Copyright © 2023 Eclipse. All rights reserved.