Hi
Can you try without groupExchanges(). To see if its the culprit of the issue.
On Wed, Apr 7, 2010 at 12:47 PM, eugene hardbread <elukyanc...@gmail.com> wrote:
> Hello
>
> I am trying to configure aggregator2 using completionSize with header
> expression:
>
> public class AggregatorTest extends CamelTestSupport{
> �...@endpointinject(uri = "mock:result")
> private MockEndpoint mockResult;
>
> �...@override
> protected RouteBuilder createRouteBuilder() throws Exception {
> return new RouteBuilder() {
> �...@override
> public void configure() throws Exception {
> from("direct:aggregatorTest")
>
> .aggregate(header("group_id")).groupExchanges().completionSize(header("quantity_in_group"))
> .to("mock:result");
>
> }
> };
> }
>
> �...@produce
> private ProducerTemplate template;
>
> �...@test
> public void testAggregator() throws InterruptedException {
> Map<String, Object> headers = new HashMap<String, Object>();
> headers.put("group_id", 1);
> headers.put("quantity_in_group", 2);
>
> mockResult.setExpectedMessageCount(1);
>
> template.sendBodyAndHeaders("direct:aggregatorTest", "message
> one", headers);
> template.sendBodyAndHeaders("direct:aggregatorTest", "message
> two", headers);
>
> mockResult.assertIsSatisfied();
>
> Exchange result = mockResult.getExchanges().get(0);
>
> List<Exchange> group = (List<Exchange>)
> result.getProperty(Exchange.GROUPED_EXCHANGE);
>
> assertListSize(group, 2);
>
> }
>
> }
>
> Nothing is sent to mockResult.
>
> Am I doing something wrong or is it an aggregator2 issue? With
> completionTimeout everything works fine. Version of Camel: current
> 2.3-SNAPSHOT from the Apache snapshot repo.
>
> Thanks,
> Eugene
>
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
