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

AbstractAggregateEventDispatcher

abstract class AbstractAggregateEventDispatcher<E : MessageExchange<*, DomainEventStream>> : AggregateMessageDispatcher<E>

Inheritors

AggregateEventDispatcher

AggregateStateEventDispatcher

Constructors

AbstractAggregateEventDispatcher

constructor()

Types

object Companion

Properties

open override val aggregateName: String

open override val contextName: String

abstract val eventHandler: EventHandler

functionRegistrar

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

abstract val messageFlux: Flux<E>

abstract val name: String

abstract val namedAggregate: NamedAggregate

abstract val parallelism: Int

abstract val scheduler: Scheduler

Functions

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

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

override fun cancel()

open override fun close()

createEventExchange

abstract fun E.createEventExchange(event: DomainEvent<*>): DomainEventExchange<*>

open fun currentContext(): Context

open override fun dispose()

fun NamedAggregate.generateId(): String

getContextAlias

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

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

open override fun isDisposed(): Boolean

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

fun NamedAggregate.materialize(): MaterializedNamedAggregate

override fun onComplete()

override fun onError(p0: Throwable)

override fun onNext(p0: Void)

override fun onSubscribe(p0: Subscription)

override fun request(p0: 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 E.toGroupKey(): Int

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String