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
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.
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
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