receive

open override fun receive(subscription: MessageSubscription): 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

subscription

The message subscription