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. |
|
open class Message<T : Any>
Represents a message that is received from the event bus in a handler. Messages have a If the message was sent specifying a reply handler it will also have a If you want to notify the sender that processing failed, then |
|
open class MessageConsumer<T : Any> : ReadStream<Message<T>>
An event bus consumer object representing a stream of message to an io.vertx.reactivex.core.eventbus.EventBus address that can be read from. The The consumer is unregistered from the event bus using the |
|
open class MessageProducer<T : Any> : WriteStream<T>
Represents a stream of message that can be written to. NOTE: This class has been automatically generated from the io.vertx.core.eventbus.MessageProducer non RX-ified interface using Vert.x codegen. |
|
open class SendContext<T : Any>
Encapsulates a message being sent from Vert.x. Used with event bus interceptors NOTE: This class has been automatically generated from the io.vertx.core.eventbus.SendContext non RX-ified interface using Vert.x codegen. |