sinkSupplier

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>>

Supplier for creating sinks for command distribution. Uses unicast mode to ensure each command reaches exactly one consumer.

See also

Sinks.UnicastSpec