wow-core/me.ahoo.wow.event/AbstractEventDispatcher/DomainEventDistributionSubscriber

DomainEventDistributionSubscriber

inner class DomainEventDistributionSubscriber : SafeSubscriber<GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>>

Subscriber that distributes domain events to aggregate-specific dispatchers.

This inner class handles grouped fluxes of domain event streams, creating and starting an aggregate event dispatcher for each named aggregate.

See also

GroupedFlux

MaterializedNamedAggregate

EventStreamExchange

AbstractEventDispatcher.newAggregateEventDispatcher

Constructors

DomainEventDistributionSubscriber

constructor()

Properties

open override val isDisposed: Boolean

open override val name: String

The name of this subscriber for logging and identification.

Functions

fun cancel()

open fun currentContext(): Context?

open fun dispose()

fun onComplete()

fun onError(t: Throwable?)

fun onNext(value: GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>?)

fun onSubscribe(s: Subscription?)

fun request(n: Long)

requestUnbounded

fun requestUnbounded()

open override fun safeOnNext(value: GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>)

Processes a grouped flux of event streams for a specific aggregate.

safeOnNextError

open fun safeOnNextError(value: GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>, throwable: Throwable)

Handles errors that occur during message processing.