vertx / io.vertx.rxjava.core.eventbus

Package io.vertx.rxjava.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.rxjava.core.eventbus.Message#body, which can be null, and also io.vertx.rxjava.core.eventbus.Message#headers, which can be empty.

If the message was sent specifying a reply handler it will also have a io.vertx.rxjava.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.rxjava.core.eventbus.Message#reply.

If you want to notify the sender that processing failed, then io.vertx.rxjava.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.