server/io.spine.server.commandbus/CommandBus/Builder

Builder

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

The Builder for CommandBus.

Functions

build

public CommandBus build()

Builds an instance of CommandBus.

newRegistry

protected CommandDispatcherRegistry newRegistry()

self

protected CommandBus.Builder self()

Returns this reference to avoid redundant casts.

setMultitenant

public CommandBus.Builder setMultitenant(Boolean multitenant)

setWatcher

public CommandBus.Builder setWatcher(CommandFlowWatcher watcher)

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.