When using the set of aggregation nodes, how does a developer tie the fan-out flow with the fan-in flow when it is included within the same message flow?