receive

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

Receives messages for the specified named aggregates.

Creates a flux that merges messages from all the sinks corresponding to the named aggregates and converts them to message exchanges.

Return

A flux of message exchanges

Parameters

namedAggregates

The set of named aggregates to receive messages for