vertx / io.vertx.reactivex.core.eventbus

Package io.vertx.reactivex.core.eventbus

Types

EventBus

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.

Message

open class Message<T : Any>

Represents a message that is received from the event bus in a handler.

Messages have a io.vertx.reactivex.core.eventbus.Message#body, which can be null, and also io.vertx.reactivex.core.eventbus.Message#headers, which can be empty.

If the message was sent specifying a reply handler it will also have a io.vertx.reactivex.core.eventbus.Message#replyAddress. In that case the message can be replied to using that reply address, or, more simply by just using io.vertx.reactivex.core.eventbus.Message#reply.

If you want to notify the sender that processing failed, then io.vertx.reactivex.core.eventbus.Message#fail can be called.

NOTE: This class has been automatically generated from the io.vertx.core.eventbus.Message non RX-ified interface using Vert.x codegen.

MessageConsumer

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 io.vertx.reactivex.core.eventbus.EventBus#consumer or io.vertx.reactivex.core.eventbus.EventBus#localConsumer creates a new consumer, the returned consumer is not yet registered against the event bus. Registration is effective after the io.vertx.reactivex.core.eventbus.MessageConsumer#handler method is invoked.

The consumer is unregistered from the event bus using the io.vertx.reactivex.core.eventbus.MessageConsumer#unregister method or by calling the io.vertx.reactivex.core.eventbus.MessageConsumer#handler with a null value..

NOTE: This class has been automatically generated from the io.vertx.core.eventbus.MessageConsumer non RX-ified interface using Vert.x codegen.

MessageProducer

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.

SendContext

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.