server/io.spine.server.event/EventBus/Builder

Builder

public class Builder extends BusBuilder<B, T, E, C, D>

The Builder for EventBus.

Functions

build

public EventBus build()

Builds an instance of EventBus.

enricher

public Optional<EventEnricher> enricher()

Obtains Enricher assigned to the bus to be built.

injectEnricher

public void injectEnricher(EventEnricher enricher)

Sets a custom Enricher for events posted to the EventBus which is being built.

newRegistry

protected DispatcherRegistry<EventClass, EventEnvelope, EventDispatcher> newRegistry()

observer

public Optional<StreamObserver<Ack>> observer()

Obtains StreamObserver assigned to the bus.

self

protected EventBus.Builder self()

Returns this reference to avoid redundant casts.

setObserver

public EventBus.Builder setObserver(StreamObserver<Ack> observer)

Assigns the observer for the post operations.

Inherited functions

addListener

public final B addListener(Listener<E> listener)

Adds a listener of the message posted to the bus being build.

appendFilter

public final B appendFilter(BusFilter<E> filter)

Adds the given filter to the builder.

checkFieldsSet

protected void checkFieldsSet()

context

protected final BoundedContext context()

filters

public final Iterable<BusFilter<E>> filters()

Obtains the filters added to this this builder by the time of the call.

injectContext

public B injectContext(BoundedContext context)

injectSystem

public B injectSystem(SystemWriteSide writeSide)

Inject the SystemWriteSide of the Bounded Context to which the built bus belongs.

injectTenantIndex

public B injectTenantIndex(TenantIndex index)

Inject the TenantIndex of the Bounded Context to which the built bus belongs.

listeners

public final Set<Listener<E>> listeners()

Obtains immutable set of listeners added to the builder by the time of the call.

removeListener

public final B removeListener(Listener<E> listener)

Removes the listener.

system

public Optional<SystemWriteSide> system()

Obtains a SystemWriteSide set in the builder.

tenantIndex

public Optional<TenantIndex> tenantIndex()

Obtains a TenantIndex set in the builder.