assertEquals("The correlation key [123] has been closed. Exchange[Message: C]", e.getMessage());
}
assertMockEndpointsSatisfied();
ap.stop();
}
public void testAggregateUseBatchSizeFromConsumer() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedBodiesReceived("A+B", "C+D+E");