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
Link copied to clipboard
constructor(snapshotHandler: SnapshotHandler, namedAggregate: NamedAggregate, name: String = "-", parallelism: Int = MessageParallelism.DEFAULT_PARALLELISM, scheduler: Scheduler, messageFlux: Flux<StateEventExchange<*>>)
Properties
Functions
Link copied to clipboard
fun NamedAggregate.aggregateId(id: String = generateId(), tenantId: String = TenantId.DEFAULT_TENANT_ID): DefaultAggregateId
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Generates a unique ID string for this NamedAggregate.
Link copied to clipboard
fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard