open class EventBus : Measured
A Vert.x event-bus is a light-weight distributed messaging system which allows different parts of your application, or different applications and services to communicate with each in a loosely coupled way.
An event-bus supports publish-subscribe messaging, point-to-point messaging and request-response messaging.
Message delivery is best-effort and messages can be lost if failure of all or part of the event bus occurs.
Please refer to the documentation for more information on the event bus.
NOTE: This class has been automatically generated from the io.vertx.core.eventbus.EventBus non RX-ified interface using Vert.x codegen.
EventBus(delegate: EventBus) |
static val __TYPE_ARG: TypeArg<EventBus> |
open fun addInterceptor(interceptor: Handler<SendContext<Any>>): EventBus
Add an interceptor that will be called whenever a message is sent from Vert.x |
|
open fun <T : Any> consumer(address: String): MessageConsumer<T>
Create a message consumer against the specified address. The returned consumer is not yet registered at the address, registration will be effective when open fun <T : Any> consumer(address: String, handler: Handler<Message<T>>): MessageConsumer<T>
Create a consumer and register it against the specified address. |
|
open fun equals(other: Any?): Boolean |
|
open fun getDelegate(): EventBus |
|
open fun hashCode(): Int |
|
open fun isMetricsEnabled(): Boolean
Whether the metrics are enabled for this measured object |
|
open fun <T : Any> localConsumer(address: String): MessageConsumer<T>open fun <T : Any> localConsumer(address: String, handler: Handler<Message<T>>): MessageConsumer<T>
Like |
|
open static fun newInstance(arg: EventBus): EventBus |
|
open fun publish(address: String, message: Any): EventBus
Publish a message. The message will be delivered to all handlers registered to the address. open fun publish(address: String, message: Any, options: DeliveryOptions): EventBus
Like |
|
open fun <T : Any> publisher(address: String): MessageProducer<T>
Create a message publisher against the specified address. The returned publisher will invoke the open fun <T : Any> publisher(address: String, options: DeliveryOptions): MessageProducer<T>
Like |
|
open fun removeInterceptor(interceptor: Handler<SendContext<Any>>): EventBus
Remove an interceptor |
|
open fun <T : Any> rxSend(address: String, message: Any): Single<Message<T>>open fun <T : Any> rxSend(address: String, message: Any, options: DeliveryOptions): Single<Message<T>>
Like |
|
open fun send(address: String, message: Any): EventBus
Sends a message. The message will be delivered to at most one of the handlers registered to the address. open fun <T : Any> send(address: String, message: Any, replyHandler: Handler<AsyncResult<Message<T>>>): EventBusopen fun <T : Any> send(address: String, message: Any, options: DeliveryOptions, replyHandler: Handler<AsyncResult<Message<T>>>): EventBus
Like open fun send(address: String, message: Any, options: DeliveryOptions): EventBus
Like |
|
open fun <T : Any> sender(address: String): MessageProducer<T>
Create a message sender against the specified address. The returned sender will invoke the open fun <T : Any> sender(address: String, options: DeliveryOptions): MessageProducer<T>
Like |
|
open fun toString(): String |