wow-core/me.ahoo.wow.event/AggregateStateEventDispatcher

AggregateStateEventDispatcher

class AggregateStateEventDispatcher(val namedAggregate: NamedAggregate, val name: String = "-", val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val messageFlux: Flux<StateEventExchange<*>>, val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, val eventHandler: EventHandler, val scheduler: Scheduler) : AbstractAggregateEventDispatcher<StateEventExchange<*>>

Constructors

AggregateStateEventDispatcher

constructor(namedAggregate: NamedAggregate, name: String = "-", parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, messageFlux: Flux<StateEventExchange<*>>, functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>, eventHandler: EventHandler, scheduler: Scheduler)

Properties

open override val aggregateName: String

open override val contextName: String

open override val eventHandler: EventHandler

functionRegistrar

open override val functionRegistrar: MessageFunctionRegistrar<MessageFunction<Any, DomainEventExchange<*>, Mono<*>>>

open override val isDisposed: Boolean

open override val messageFlux: Flux<StateEventExchange<*>>

open override val name: String

open override val namedAggregate: NamedAggregate

open override val parallelism: Int

open override val scheduler: Scheduler

Functions

fun NamedAggregate.aggregateId(id: String = generateId(), tenantId: String = TenantId.DEFAULT_TENANT_ID): DefaultAggregateId

fun <T> NamedAggregate.aggregateType(): Class<T>?

asAggregateMetadata

fun <C : Any, S : Any> NamedAggregate.asAggregateMetadata(): AggregateMetadata<C, S>

fun cancel()

open override fun close()

createEventExchange

open override fun StateEventExchange<*>.createEventExchange(event: DomainEvent<*>): DomainEventExchange<*>

open fun currentContext(): Context?

open fun dispose()

fun NamedAggregate.generateId(): String

Generates a unique ID string for this NamedAggregate.

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

open override fun handleExchange(exchange: StateEventExchange<*>): Mono<Void>

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun NamedAggregate.materialize(): MaterializedNamedAggregate

fun onComplete()

fun onError(t: Throwable?)

fun onNext(value: Void?)

fun onSubscribe(s: Subscription?)

fun request(n: Long)

requestUnbounded

fun requestUnbounded()

requiredAggregateType

fun <T> NamedAggregate.requiredAggregateType(): Class<T>

open override fun run()

open fun safeOnNext(value: Void)

safeOnNextError

open fun safeOnNextError(value: Void, throwable: Throwable)

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

open override fun StateEventExchange<*>.toGroupKey(): Int

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String