Re: AW: Aggregator - complete when newExchange.header('"x") != oldExchange.header("x)

2014-03-11 Thread Andrzej Gdula
Ok, Skip NPE for now since it's a problem with JdbcAggregationRepository i suppose. Anyway the test I've created fails. please take a look at https://github.com/agdula/camel-test there are Two test cases https://github.com/agdula/camel-test/blob/master/src/test/java/com/pb/psep/testbase/Aggregato

Re: AW: Aggregator - complete when newExchange.header('"x") != oldExchange.header("x)

2014-03-07 Thread Andrzej Gdula
I've tried to add state but it does not work This does not work I've tried adding ".eagerCheckCompletion()" but with this i get NPE. It happens when each message is different (like A B C E insread of A A B B C C). -- View this message in context: http://camel.465427.

Re: AW: Aggregator - complete when newExchange.header('"x") != oldExchange.header("x)

2014-03-07 Thread Andrzej Gdula
What i want is to group subsequent messages. If there is a message that doesn't fit to messages i've already aggregated then i want to stop aggregation and start to aggregate from that message. Im my case correlation correlationExpression in my case must be 'constant(true)'. I want to process fil

Aggregator - complete when newExchange.header('"x") != oldExchange.header("x)

2014-03-07 Thread Andrzej Gdula
I've got a sequence of input files. I need to process them in order. I also need to group subsequent messages messages with the same xpath(/Root/Type) in a list. Is there a way to do this using aggregator ? eg. File 1 ( contains A ) File 2 ( contains A ) File 3 ( contains A ) File 4 ( contains B