MessageParallelism

Utility object for calculating message processing parallelism.

Provides default parallelism settings and functions to compute grouping keys for parallel message processing based on aggregate IDs.

Properties

Default parallelism level for message processing.

fun AggregateIdCapable.toGroupKey(parallelism: Int = DEFAULT_PARALLELISM): Int

Computes a grouping key for parallel processing based on the aggregate ID.