THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Wiki Markup |
---|
{snippet:id=example|lang=java|url=camel/trunk/camel-core/src/test/java/org/apache/camel/processor/MulticastTest.java} |
If you want to aggregate the whatever the incoming messages or outgoing messages within the multicast, here is an example
Using the Fluent Builders
Wiki Markup |
---|
{snippet:id=example|lang=java|url=camel/trunk/camel-core/src/test/java/org/apache/camel/processor/MulticastAnotherAggregatorTest.java} |
For further examples of this pattern in use you could look at one of the junit test case
Stop processing in case of exception
...