io.spine.server.event

Class EventBus.Builder

java.lang.Object

io.spine.server.bus.BusBuilder<EventBus.Builder,io.spine.core.Event,EventEnvelope,EventClass,EventDispatcher>

io.spine.server.event.EventBus.Builder

Enclosing class:

EventBus

@CanIgnoreReturnValue
public static class EventBus.Builder
extends BusBuilder<EventBus.Builder,io.spine.core.Event,EventEnvelope,EventClass,EventDispatcher>

The Builder for EventBus.

Nested Class Summary

Nested classes/interfaces inherited from class io.spine.server.bus.BusBuilder

BusBuilder.FieldCheck

Method Summary

Modifier and Type	Method and Description
EventBus	build() Builds an instance of EventBus.
java.util.Optional<EventEnricher>	enricher() Obtains Enricher assigned to the bus to be built.
void	injectEnricher(EventEnricher enricher) Sets a custom Enricher for events posted to the EventBus which is being built.
protected DispatcherRegistry<EventClass,EventEnvelope,EventDispatcher>	newRegistry()
java.util.Optional<io.grpc.stub.StreamObserver<io.spine.core.Ack>>	observer() Obtains StreamObserver assigned to the bus.
protected EventBus.Builder	self() Returns this reference to avoid redundant casts.
EventBus.Builder	setObserver(io.grpc.stub.StreamObserver<io.spine.core.Ack> observer) Assigns the observer for the Bus.post(Signal, StreamObserver) operations.

Methods inherited from class io.spine.server.bus.BusBuilder

addListener, appendFilter, checkFieldsSet, context, filters, listeners, removeListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

newRegistry

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

Specified by:

newRegistry in class BusBuilder<EventBus.Builder,io.spine.core.Event,EventEnvelope,EventClass,EventDispatcher>

injectEnricher

public void injectEnricher(EventEnricher enricher)

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

If the Enricher is not set, the enrichments will NOT be supported for the EventBus instance built.

Parameters:

enricher - the Enricher for events or null if enrichment is not supported

enricher

public java.util.Optional<EventEnricher> enricher()

Obtains Enricher assigned to the bus to be built.

setObserver

public EventBus.Builder setObserver(io.grpc.stub.StreamObserver<io.spine.core.Ack> observer)

Assigns the observer for the Bus.post(Signal, StreamObserver) operations.

observer

public java.util.Optional<io.grpc.stub.StreamObserver<io.spine.core.Ack>> observer()

Obtains StreamObserver assigned to the bus.

build

@CheckReturnValue
public EventBus build()

Builds an instance of EventBus.

This method is supposed to be called internally when building an enclosing BoundedContext.

Specified by:

build in class BusBuilder<EventBus.Builder,io.spine.core.Event,EventEnvelope,EventClass,EventDispatcher>

self

protected EventBus.Builder self()

Description copied from class: BusBuilder

Returns this reference to avoid redundant casts.

Specified by:

self in class BusBuilder<EventBus.Builder,io.spine.core.Event,EventEnvelope,EventClass,EventDispatcher>