getOrInitialize

open override fun getOrInitialize(namedAggregate: NamedAggregate): Scheduler

Gets the cached scheduler for the aggregate or creates a new parallel scheduler.

This method implements lazy initialization with caching. If a scheduler already exists for the given aggregate, it returns the cached instance. Otherwise, it creates a new parallel scheduler with a descriptive name.

Return

the dedicated scheduler for this aggregate

Parameters

namedAggregate

the aggregate for which to get or create a scheduler