The below logs show the various size's of the list. Looks like the below line
of code has something wrong in it.
Please help solve this.
*from("file:/work_dir/camel_proj/data/input?delete=true")
.log("Starting to process big file: ${header.CamelFileName}")
.split(body().tokenize("\n")).streaming()
.aggregate(header("CamelFileName"), new
MyListAggregation()).completionSize(2000).onCompletion()*
fileToQueue.log.1:2011-11-02 09:51:40,723 INFO [pool-2-thread-1]
camel.ListParser - Size of MyList : 23011
fileToQueue.log.2:2011-11-02 09:51:39,103 INFO [pool-2-thread-10]
camel.ListParser - Size of MyList : 21070
fileToQueue.log.3:2011-11-02 09:51:37,820 INFO [pool-2-thread-9]
camel.ListParser - Size of MyList : 19094
fileToQueue.log.4:2011-11-02 09:51:36,881 INFO [pool-2-thread-8]
camel.ListParser - Size of MyList : 17085
fileToQueue.log.5:2011-11-02 09:51:36,003 INFO [pool-2-thread-7]
camel.ListParser - Size of MyList : 17011
fileToQueue.log.6:2011-11-02 09:51:35,018 INFO [pool-2-thread-6]
camel.ListParser - Size of MyList : 13074
fileToQueue.log.7:2011-11-02 09:51:33,583 INFO [pool-2-thread-4]
camel.ListParser - Size of MyList : 9052
fileToQueue.log.7:2011-11-02 09:51:34,215 INFO [pool-2-thread-5]
camel.ListParser - Size of MyList : 11064
fileToQueue.log.8:2011-11-02 09:51:31,116 INFO [pool-2-thread-1]
camel.ListParser - Size of MyList : 2017
fileToQueue.log.8:2011-11-02 09:51:31,615 INFO [pool-2-thread-2]
camel.ListParser - Size of MyList : 4010
fileToQueue.log.8:2011-11-02 09:51:32,887 INFO [pool-2-thread-3]
camel.ListParser - Size of MyList : 7024
--
View this message in context:
http://camel.465427.n5.nabble.com/synchronization-issue-tp4956228p4958123.html
Sent from the Camel - Users mailing list archive at Nabble.com.
