Whats the code in the MyAggregationStrategy ?
Make sure you do this correctly, when setting the data on the exchange
in this strategy.
On Tue, Nov 8, 2011 at 8:17 PM, ebinsingh
<ebenezer.si...@verizonwireless.com> wrote:
> Thanks a lot.
>
> Below is the code am using and I get this error message. Not sure what is
> missing.
>
> from("file:C:\\camelProject\\data\\inbox\\")
> .log("Starting to process big file: ${header.CamelFileName}")
> .split(body().tokenize("\n")).streaming()
> .unmarshal(csv).convertBodyTo(List.class)
> .bean(Parser1.class,"create_fp_record1")
> .aggregate(constant(true), new
> MyAggregationStrategy()).completionSize(2000)
>
> .to("file:C:\\camelProject\\data\\outbox\\?fileExist=Append&fileName=${file:onlyname.noext}");
>
>
> public String create_fp_record1(List<String> marsRecord) {
> log.debug("START to parse record: ");
> StringBuilder str = new StringBuilder(300);
> str.append("L2|");
> str.append(marsRecord.get(1));
> str.append(delimeter);
> .
> .
> .
> .
> .
> str.append(delimeter);
> str.append("xx");
> log.debug("END parse record");
> return str;
>
>
> I see these logs as well as the Error log below. Not sure how these become
> null.
>
> 2011-11-08 13:42:35,827 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] bean.BeanProcessor - Setting bean
> invocation result on the IN message: L2|204043110533530
>
> 2011-11-08 13:42:35,827 INFO [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Found 3 packages with 15 @Converter classes to load
> 2011-11-08 13:42:35,827 INFO [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.DefaultTypeConverter - Loaded
> 154 core type converters (total 154 type converters)
> 2011-11-08 13:42:35,827 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.DefaultTypeConverter - Loading
> additional type converters ...
> 2011-11-08 13:42:35,827 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve
> list of packages, from url:
> jar:file:/C:/Exec/apache-camel/lib/camel-spring-ws-2.8.1.jar!/META-INF/services/org/apache/camel/TypeConverter
> 2011-11-08 13:42:35,827 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve
> list of packages, from url:
> jar:file:/C:/Exec/apache-camel/lib/camel-spring-integration-2.8.1.jar!/META-INF/services/org/apache/camel/TypeConverter
> 2011-11-08 13:42:35,842 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve
> list of packages, from url:
> jar:file:/C:/Exec/apache-camel/lib/camel-core-2.8.1.jar!/META-INF/services/org/apache/camel/TypeConverter
> 2011-11-08 13:42:35,842 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve
> list of packages, from url:
> file:/C:/MyWorkspaces/camelTest/src/resources/META-INF/services/org/apache/camel/TypeConverter
> 2011-11-08 13:42:35,842 INFO [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Loaded 2 @Converter classes
> 2011-11-08 13:42:35,842 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] impl.DefaultPackageScanClassResolver -
> Searching for annotations of org.apache.camel.Converter in packages:
> [com.verizon.learn.camel.utils]
> 2011-11-08 13:42:35,842 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] impl.DefaultPackageScanClassResolver -
> Found: [class com.verizon.learn.camel.utils.NamesConverter]
> 2011-11-08 13:42:35,842 INFO [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.AnnotationTypeConverterLoader
> - Found 1 packages with 1 @Converter classes to load
> 2011-11-08 13:42:35,842 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.DefaultTypeConverter - Loading
> additional type converters done
> 2011-11-08 13:42:35,842 INFO [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] converter.DefaultTypeConverter - Loaded
> additional 6 type converters (total 160 type converters) in 0.015 seconds
> 2011-11-08 13:42:35,842 DEBUG [Camel (camel-1) thread #0 -
> file://C:camelProjectdatainboxmars] aggregate.AggregateProcessor -
> Aggregation complete for correlation key true sending aggregated exchange:
> Exchange[Message: null
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/correlationExpression-while-Aggregating-tp4975191p4975364.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
Claus Ibsen
-----------------
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
