receive

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

Receives messages from both local and distributed buses.

Local messages are received for local aggregates, while distributed messages are filtered to exclude those already handled locally.

Return

A merged flux of message exchanges from local and distributed sources

Parameters

namedAggregates

The set of named aggregates to receive messages for