Hi all,
I had some trouble figuring out how to multicast to some pipelines. I
eventually found a [working] definition, but I also expected other forms to
work such as:
.multicast().aggregationStrategy(AggregationStrategies.groupedExchange())
.pipeline("A", "B")
.pipeline("C", "D")
.end()
or
.multicast().aggregationStrategy(AggregationStrategies.groupedExchange())
.to("A", "B")
.to("C", "D")
.end()
yet they all fail (in the sense that they all receive the original START
incoming payload. Can anyone explain how this is expected behavior?
Best,
Edoardo
[working]: https://gist.github.com/ecausarano/4b66294464741b9f626890b29ea0aec2
