receiveMessage
Creates a flux of messages for the specified named aggregate.
This method should return a reactive stream of messages that are destined for the given aggregate. The implementation should handle message sourcing, filtering, and any necessary transformations.
Return
A Flux of messages for the aggregate. May be empty if no messages are available.
Parameters
namedAggregate
The named aggregate to receive messages for. Must not be null.
Throws
if the namedAggregate is invalid or unsupported.
if there are issues with message sourcing or connectivity.