Package | Description |
---|---|
io.vertx.core | |
io.vertx.core.eventbus | |
io.vertx.core.spi.metrics | |
io.vertx.rxjava.core.eventbus |
Modifier and Type | Method and Description |
---|---|
EventBus |
Vertx.eventBus()
Get the event bus object.
|
Modifier and Type | Method and Description |
---|---|
EventBus |
EventBus.addInterceptor(Handler<SendContext> 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.
|
EventBus |
EventBus.removeInterceptor(Handler<SendContext> interceptor)
Remove an interceptor
|
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)
Like
send(String, Object, DeliveryOptions) but specifying a replyHandler that will be called if the recipient
subsequently replies to the message. |
<T> EventBus |
EventBus.send(String address,
Object message,
Handler<AsyncResult<Message<T>>> replyHandler)
Like
send(String, Object) but specifying a replyHandler that will be called if the recipient
subsequently replies to the message. |
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 |
---|---|
EventBusMetrics |
VertxMetrics.createMetrics(EventBus eventBus)
Provides the event bus metrics SPI when the event bus is created.
No specific thread and context can be expected when this method is called.
This method should be called only once.
|
default void |
VertxMetrics.eventBusInitialized(EventBus bus)
Metrics cannot use the event bus in their constructor as the event bus is not yet initialized.
|
Modifier and Type | Method and Description |
---|---|
static EventBus |
EventBus.newInstance(EventBus arg) |
Constructor and Description |
---|
EventBus(EventBus delegate) |
Copyright © 2015. All rights reserved.