server/io.spine.server.bus/BusBuilder

BusBuilder

public abstract class BusBuilder<B extends BusBuilder<B, T, E, C, D>, T extends Signal<?, ?, ?>, E extends SignalEnvelope<? extends Object, T, ? extends Object>, C extends MessageClass<? extends Message>, D extends MessageDispatcher<C, E>>

The implementation base for the bus builders.

Parameters

<E>

the type of SignalEnvelope posted by the bus

<T>

the type of Signal posted by the bus

<B>

the own type of the builder

Inheritors

Builder

Constructors

BusBuilder

protected void BusBuilder()

Creates a new instance of the bus builder.

Types

FieldCheck

public final class FieldCheck

Verifies if required fields of a BusBuilder are set.

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.

build

public abstract Bus<? extends Object, E, ? extends Object, ? extends Object> build()

Creates new instance of Bus with the set parameters.

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.

newRegistry

protected abstract DispatcherRegistry<C, E, D> newRegistry()

removeListener

public final B removeListener(Listener<E> listener)

Removes the listener.

self

protected abstract B self()

Returns this reference to avoid redundant casts.

system

public Optional<SystemWriteSide> system()

Obtains a SystemWriteSide set in the builder.

tenantIndex

public Optional<TenantIndex> tenantIndex()

Obtains a TenantIndex set in the builder.