Optional method which can be called to indicate when the registration has been propagated across the cluster.
Optional method which can be called to indicate when the registration has been propagated across the cluster.
Pipe this ReadStream to the WriteStream.
Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the handler will be
called with the result.
Pipe this ReadStream to the WriteStream.
Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the handler will be
called with the result.
Set the number of messages this registration will buffer when this stream is paused. The default
value is 1000.
When a new value is set, buffered messages may be discarded to reach the new value. The most recent messages will be kept.
Unregisters the handler which created this registration
Unregisters the handler which created this registration
Generated using TypeDoc
An event bus consumer object representing a stream of message to an EventBus address that can be read from.
The {@link EventBus#consumer} or {@link EventBus#localConsumer} creates a new consumer, the returned consumer is not yet registered against the event bus. Registration is effective after the {@link MessageConsumer#handler} method is invoked.
The consumer is unregistered from the event bus using the {@link MessageConsumer#unregister} method or by calling the {@link MessageConsumer#handler} with a null value..