public class MulticastParallelStressTest extends ContextTestSupport {
public void testTwoMulticast() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedBodiesReceived("ABCD", "ABCD");
mock.expectsAscending().header("id");
template.sendBodyAndHeader("direct:start", "", "id", 1);
template.sendBodyAndHeader("direct:start", "", "id", 2);
assertMockEndpointsSatisfied();