Hi,

I am trying to SFTP/FTP CSV record, and unmarshal as model object.

I am getting the following exceptions -" Exhausted after delivery attempt: 1 
caught: java.lang.IllegalArgumentException: No records have been defined in the 
CSV", though I've records in the file.



However, if I've the file in local folder (end point is 'file'), its working.  
Am I missing anything in the following route? Please help on this.

Thanks

chandra





<cml:camelContext trace="true"      autoStartup="true" 
xmlns="http://camel.apache.org/schema/spring";>

            <cml:route id="employee-fetch-route" routePolicyRef="startPolicy" 
autoStartup="true">





            <cml:from 
uri="sftp://ftp-user:fp88!*5...@ftp.order.com/datatransfer/ps-drop/TEST/backup?noop=true"/>

                    <cml:split streaming="true">

                        <cml:tokenize token="\n" group="10000" />

                        <cml:unmarshal ref="bindyDataformat" >

                              <cml:bindy type="Csv"  
classType="com.camel.feed.employee.Employee"  />

                        </cml:unmarshal>

                        <cml:log message="Employee Details are ${body}" 
loggingLevel="WARN" />

                      <cml:bean ref="employeeProcessor" method="processFeed" />

                   </cml:split>

             </cml:route>

</cml:camelContext>



 [r/Delta-HR/ps-drop/TEST/backup] DefaultErrorHandler            ERROR Failed 
delivery for (MessageId: ID-EVG60LT-3-CKALI-61007-1351100820524-0-1 on 
ExchangeId: ID-EVG60LT-3-CKALI-61007-1351100820524-0-3). Exhausted after 
delivery attempt: 1 caught: java.lang.IllegalArgumentException: No records have 
been defined in the CSV

java.lang.IllegalArgumentException: No records have been defined in the CSV

      at 
org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat.unmarshal(BindyCsvDataFormat.java:185)

      at 
org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:57)

      at 
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)

      at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)

      at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)

      at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)

      at 
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)

      at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)

      at 
org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)

      at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)

      at 
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)

      at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)

      at 
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)

      at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)

      at 
org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)

      at 
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)

      at 
org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)

      at 
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)



Reply via email to