Add an interceptor that will be called whenever a message is received by Vert.x
Add an interceptor that will be called whenever a message is sent from Vert.x
Register a predicate to invoke when verifying if an object is forbidden to be encoded/decoded as {@link ClusterSerializable}.
This is only used when Vert.x is clustered.
Set selector to be invoked when the bus has not found any codec for a Message body.
The selector must return the name of a codec which has been registered with either {@link EventBus#registerCodec} or {@link EventBus#registerDefaultCodec}.
Create a message consumer against the specified address.
The returned consumer is not yet registered at the address, registration will be effective when {@link MessageConsumer#handler} is called.
Create a consumer and register it against the specified address.
Whether the metrics are enabled for this measured object
Like {@link EventBus#consumer} but the address won't be propagated across the cluster.
Like {@link EventBus#consumer} but the address won't be propagated across the cluster.
Publish a message.
The message will be delivered to all handlers registered to the address.
Like {@link EventBus#publish} but specifying options that can be used to configure the delivery.
Create a message publisher against the specified address.
The returned publisher will invoke the {@link EventBus#publish} method when the stream {@link WriteStream#write} method is called with the publisher address and the provided data.
Like {@link EventBus#publisher} but specifying delivery options that will be used for configuring the delivery of the message.
Register a message codec.
You can register a message codec if you want to send any non standard message across the event bus. E.g. you might want to send POJOs directly across the event bus.
To use a message codec for a send, you should specify it in the delivery options.
Remove an interceptor that was added by {@link EventBus#addInboundInterceptor}
Remove an interceptor that was added by {@link EventBus#addOutboundInterceptor}
Sends a message and specify a replyHandler that will be called if the recipient
subsequently replies to the message.
The message will be delivered to at most one of the handlers registered to the address.
Sends a message and specify a replyHandler that will be called if the recipient
subsequently replies to the message.
The message will be delivered to at most one of the handlers registered to the address.
Like {@link EventBus#request} but specifying options that can be used to configure the delivery.
Like {@link EventBus#request} but specifying options that can be used to configure the delivery.
Sends a message.
The message will be delivered to at most one of the handlers registered to the address.
Like {@link EventBus#send} but specifying options that can be used to configure the delivery.
Create a message sender against the specified address.
The returned sender will invoke the {@link EventBus#send} method when the stream {@link WriteStream#write} method is called with the sender address and the provided data.
Like {@link EventBus#sender} but specifying delivery options that will be used for configuring the delivery of the message.
Register a predicate to invoke when verifying if an object is allowed to be encoded/decoded as Serializable.
This is only used when Vert.x is clustered.
Unregister a message codec.
Generated using TypeDoc
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.