Class EventBus

moduleio.vertx.ceylon.core3.5.0 (jvm)

Index
Search
Filter

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.

Anything
- Object
  - Basic ...and other supertypes
    EventBus ...and other supertypes

EventBus
- Basic
  - Identifiable
  - Object
    Anything
- Measured

no subtypes hierarchy

Initializer
`EventBus(EventBus unknown)`

Inherited Attributes
Attributes inherited from: `Object` `hash`, `string`

Methods
`addInterceptor`	`shared default EventBus addInterceptor(Anything(SendContext<unknown>) interceptor)` Add an interceptor that will be called whenever a message is sent from Vert.x Parameters: `interceptor` the interceptor
`consumer`	`shared default MessageConsumer<T?> consumer<T>(String address)` Create a message consumer against the specified address. The returned consumer is not yet registered at the address, registration will be effective when handler is called. Parameters: `address` the address that it will register it at
`consumer`	`shared default MessageConsumer<T?> consumer<T>(String address, Anything(Message<T?>) handler)` Create a consumer and register it against the specified address. Parameters: `address` the address that will register it at `handler` the handler that will process the received messages
`isMetricsEnabled`	`shared actual default Boolean isMetricsEnabled()` Whether the metrics are enabled for this measured object Refines `Measured.isMetricsEnabled`
`localConsumer`	`shared default MessageConsumer<T?> localConsumer<T>(String address)` Like consumer but the address won't be propagated across the cluster. Parameters: `address` the address to register it at
`localConsumer`	`shared default MessageConsumer<T?> localConsumer<T>(String address, Anything(Message<T?>) handler)` Like consumer but the address won't be propagated across the cluster. Parameters: `address` the address that will register it at `handler` the handler that will process the received messages
`publish`	`shared default EventBus publish(String address, Object? message)` Publish a message. The message will be delivered to all handlers registered to the address. Parameters: `address` the address to publish it to `message` the message, may be `null`
`publish`	`shared default EventBus publish(String address, Object? message, DeliveryOptions options)` Like publish but specifying `options` that can be used to configure the delivery. Parameters: `address` the address to publish it to `message` the message, may be `null` `options` the delivery options
`publisher`	`shared default MessageProducer<T?> publisher<T>(String address)` Create a message publisher against the specified address. The returned publisher will invoke the publish method when the stream write method is called with the publisher address and the provided data. Parameters: `address` The address to publish it to
`publisher`	`shared default MessageProducer<T?> publisher<T>(String address, DeliveryOptions options)` Like publisher but specifying delivery options that will be used for configuring the delivery of the message. Parameters: `address` the address to publish it to `options` the delivery options
`removeInterceptor`	`shared default EventBus removeInterceptor(Anything(SendContext<unknown>) interceptor)` Remove an interceptor Parameters: `interceptor` the interceptor
`send`	`shared default EventBus send(String address, Object? message)` Sends a message. The message will be delivered to at most one of the handlers registered to the address. Parameters: `address` the address to send it to `message` the message, may be `null`
`send`	`shared default EventBus send(String address, Object? message, DeliveryOptions options)` Like send but specifying `options` that can be used to configure the delivery. Parameters: `address` the address to send it to `message` the message, may be `null` `options` delivery options
`send`	`shared default EventBus send<T>(String address, Object? message, Anything(Throwable\|Message<T?>) replyHandler)` Like send but specifying a `replyHandler` that will be called if the recipient subsequently replies to the message. Parameters: `address` the address to send it to `message` the message, may be `null` `replyHandler` reply handler will be called when any reply from the recipient is received, may be `null`
`send`	`shared default EventBus send<T>(String address, Object? message, DeliveryOptions options, Anything(Throwable\|Message<T?>) replyHandler)` Like send but specifying a `replyHandler` that will be called if the recipient subsequently replies to the message. Parameters: `address` the address to send it to `message` the message, may be `null` `options` delivery options `replyHandler` reply handler will be called when any reply from the recipient is received, may be `null`
`sender`	`shared default MessageProducer<T?> sender<T>(String address)` Create a message sender against the specified address. The returned sender will invoke the send method when the stream write method is called with the sender address and the provided data. Parameters: `address` the address to send it to
`sender`	`shared default MessageProducer<T?> sender<T>(String address, DeliveryOptions options)` Like sender but specifying delivery options that will be used for configuring the delivery of the message. Parameters: `address` the address to send it to `options` the delivery options

Inherited Methods
Methods inherited from: `Object` `equals`
Methods inherited from: `Measured` `isMetricsEnabled()`