receive

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

Receives state event exchanges for the specified named aggregates and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification and subscriber information.

Return

a Flux of state event exchanges

Parameters

namedAggregates

the set of named aggregates to receive state events for