wow-core/me.ahoo.wow.eventsourcing.snapshot/AggregateSnapshotDispatcher

AggregateSnapshotDispatcher

class AggregateSnapshotDispatcher(snapshotHandler: SnapshotHandler, val namedAggregate: NamedAggregate, val name: String = "-", val parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, val scheduler: Scheduler, val messageFlux: Flux<StateEventExchange<*>>) : AggregateMessageDispatcher<StateEventExchange<*>> , ProcessorInfo

Constructors

constructor(snapshotHandler: SnapshotHandler, namedAggregate: NamedAggregate, name: String = "-", parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, scheduler: Scheduler, messageFlux: Flux<StateEventExchange<*>>)

Properties

aggregateName

open override val aggregateName: String

contextName

open override val contextName: String

messageFlux

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

name

open override val name: String

namedAggregate

open override val namedAggregate: NamedAggregate

parallelism

open override val parallelism: Int

processorName

open override val processorName: String

scheduler

open override val scheduler: Scheduler

Functions

aggregateId

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

aggregateType

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

cancel

override fun cancel()

open override fun close()

currentContext

open fun currentContext(): Context

dispose

open override fun dispose()

generateId

fun NamedAggregate.generateId(): String

getContextAlias

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

handleExchange

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

isDisposed

open override fun isDisposed(): Boolean

isLocal

fun NamedAggregate.isLocal(): Boolean

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

materialize

fun NamedAggregate.materialize(): MaterializedNamedAggregate

onComplete

override fun onComplete()

onError

override fun onError(p0: Throwable)

onNext

override fun onNext(p0: Void)

onSubscribe

override fun onSubscribe(p0: Subscription)

request

override fun request(p0: Long)

requestUnbounded

fun requestUnbounded()

requiredAggregateType

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

run

open override fun run()

safeOnNext

open fun safeOnNext(value: Void)

safeOnNextError

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

toEventNamedAggregate

fun NamedAggregate.toEventNamedAggregate(eventName: String): EventNamedAggregate

toGroupKey

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

toNamedAggregateString

fun NamedAggregate.toNamedAggregateString(): String

toStringWithAlias

fun NamedAggregate.toStringWithAlias(): String