Quantcast

Camel Bindy problem with separator

classic Classic list List threaded Threaded
10 messages Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Camel Bindy problem with separator

dlin7971
This post has NOT been accepted by the mailing list yet.
Hi,there. I used Jboss5+Spring2.5+camel 2.6. I encounter java.lang.IllegalArgumentException(I paste the exception's detail underneath. From the exception, it seems the separator has not been defined.
I searched quite a lot. However, No solution has been found. Any help? Thanks in advance. By the way, I use camel-bindy-2.6.0.jar and camel-jboss-2.5.0.jar.

My csv file:

csv file first line as:
"stockid";"make";"model";"deriv";"series";"registration";"chassis";"engine";"year";"klms";"body";"colour";"enginesize";"trans";"fuel";"options";"desc";"status";"Reserve_price";"nvic"

csv file data as:
"SS552";"TOYOTA";"KLUGER";"CV 4X4";"MCU28R UPGRADE";"TBA";"";"";"2005";"155000";"4D WAGON";"BLACK";"3.3 LTR";"5 Sp Auto";"MULTI POINT FINJ";"POWER MIRRORS, POWER STEERING, POWER WINDOWS, CRUISE CONTROL, ENGINE IMMOBILISER, BRAKE ASSIST, DUAL AIRBAG PACKAGE, ANTI-LOCK BRAKING, CENTRAL LOCKING REMOTE CONTROL, ALARM SYSTEM/REMOTE ANTI THEFT, AUTOMATIC AIR CON / CLIMATE CONTROL, ELECTRONIC BRAKE FORCE DISTRIBUTION, CLOTH TRIM, LIMITED SLIP DIFFERENTIAL, RADIO CD WITH 6 SPEAKERS";"Dual Airbag Package, Anti-lock Braking, Automatic Air Con / Climate Control, Alarm System/Remote Anti Theft, Brake Assist, Cruise Control, Central Locking Remote Control, Cloth Trim, Electronic Brake Force Distribution, Engine Immobiliser, Limited Slip Differential, Power Mirrors, Power Steering, Power Windows, Radio CD with 6 Speakers CV GOOD KLMS AUTO POWER OPTIONS GOOD KLMS   ";"Used";"";"EZR05I"

My data model:
Even I changed the csv file by using "," or ";" and try (separator="," or separator=";"), the same exception appeared

@CsvRecord( separator="\",\"",skipFirstLine=true )
public class CsvUploadProduct {
        @DataField(pos = 1)
        private String stockid;
        @DataField(pos = 2)
        private String make;
        @DataField(pos = 3)
        private String model;
        @DataField(pos = 4)
        private String deriv;
        @DataField(pos = 5)
        private String series;
        @DataField(pos = 6)
        private String registration;
        @DataField(pos = 7)
        private String chassis;
        @DataField(pos = 8)
        private String engine;
        @DataField(pos = 9)
        private int year;
        @DataField(pos = 10,precision = 1)
        private double klms;
        @DataField(pos = 11)
        private String body;
        @DataField(pos = 12)
        private String colour;
        @DataField(pos = 13)
        private String enginesize;
        @DataField(pos = 14)
        private String trans;
        @DataField(pos = 15)
        private String fuel;
        @DataField(pos = 16)
        private String options;
        @DataField(pos = 17)
        private String desc;
        @DataField(pos = 18)
        private String status;
        @DataField(pos = 19,precision = 1)
        private double price;
        @DataField(pos = 20)
        private String nvic;
        public String getStockid() {
                return stockid;
        }
        public void setStockid(String stockid) {
                this.stockid = stockid;
        }
        public String getMake() {
                return make;
        }
        public void setMake(String make) {
                this.make = make;
        }
        public String getModel() {
                return model;
        }
        public void setModel(String model) {
                this.model = model;
        }
        public String getDeriv() {
                return deriv;
        }
        public void setDeriv(String deriv) {
                this.deriv = deriv;
        }
        public String getSeries() {
                return series;
        }
        public void setSeries(String series) {
                this.series = series;
        }
        public String getRegistration() {
                return registration;
        }
        public void setRegistration(String registration) {
                this.registration = registration;
        }
        public String getChassis() {
                return chassis;
        }
        public void setChassis(String chassis) {
                this.chassis = chassis;
        }
        public String getEngine() {
                return engine;
        }
        public void setEngine(String engine) {
                this.engine = engine;
        }
        public int getYear() {
                return year;
        }
        public void setYear(int year) {
                this.year = year;
        }
        public double getKlms() {
                return klms;
        }
        public void setKlms(double klms) {
                this.klms = klms;
        }
        public String getBody() {
                return body;
        }
        public void setBody(String body) {
                this.body = body;
        }
        public String getColour() {
                return colour;
        }
        public void setColour(String colour) {
                this.colour = colour;
        }
        public String getEnginesize() {
                return enginesize;
        }
        public void setEnginesize(String enginesize) {
                this.enginesize = enginesize;
        }
        public String getTrans() {
                return trans;
        }
        public void setTrans(String trans) {
                this.trans = trans;
        }
        public String getFuel() {
                return fuel;
        }
        public void setFuel(String fuel) {
                this.fuel = fuel;
        }
        public String getOptions() {
                return options;
        }
        public void setOptions(String options) {
                this.options = options;
        }
        public String getDesc() {
                return desc;
        }
        public void setDesc(String desc) {
                this.desc = desc;
        }
        public String getStatus() {
                return status;
        }
        public void setStatus(String status) {
                this.status = status;
        }
        public double getPrice() {
                return price;
        }
        public void setPrice(double price) {
                this.price = price;
        }
        public String getNvic() {
                return nvic;
        }
        public void setNvic(String nvic) {
                this.nvic = nvic;
        }

My Route:

public class FtpRouteBuilder extends RouteBuilder{

        public void configure() throws Exception {
                //long delay = 60 * 60 * 1000L;
                long delay = 60 * 1000L;


                from("ftp://localhost:21/fileForUpload?username=jerry&password=12345678&localWorkDirectory=c:/tmp&readLock=true&delete=true&binary=true&consumer.delay=" + delay)
                .choice()
                .when(header("CamelFileName").regex("^.*(xml|XML)$")).convertBodyTo(String.class)
                        .beanRef("addProductFromFileService", "uploadFromFile")
                        .to("file://c:/done")
                .when(header("CamelFileName").regex("^.*(CSV|csv|CSL|csl)$"))
                        .unmarshal().bindy(BindyType.Csv, "com.suv.camel.bindy")
                        //.unmarshal(new BindyCsvDataFormat("com.suv.camel.bindy"))
                        .beanRef("addProductFromFileService", "uploadFromFile")
                      .otherwise()
                            .to("file://c:/wrongFormat");

        }

My Spring applicationContext_camelFileTransfer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
        xmlns:camel="http://camel.apache.org/schema/spring"
        xmlns:jee="http://www.springframework.org/schema/jee" xmlns:jaxws="http://cxf.apache.org/jaxws"
        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"
        default-dependency-check="none" default-lazy-init="false">

    <bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/>
   
    <bean id="jbossResolver" class="org.apache.camel.jboss.JBossPackageScanClassResolver"/>
   
    <bean id="ftpRouteBuilder" class="com.suv.camel.ftp.route.FtpRouteBuilder"/>
     
     <camelContext xmlns="http://camel.apache.org/schema/spring">
                 <routeBuilder ref="ftpRouteBuilder"/>
        </camelContext>

</beans>

Exception:

ERROR [DefaultErrorHandler] Failed delivery for exchangeId: ID-lin-7c51f5e4699-1711-1302923431031-0-10. Exhausted after delivery attempt: 1 caught: java.lang.IllegalArgumentException: The separator has not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified
java.lang.IllegalArgumentException: The separator has not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified
        at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:277)
        at org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat.unmarshal(BindyCsvDataFormat.java:123)
        at org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:56)
        at org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:299)
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:208)
        at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:125)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:80)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:299)
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:208)
        at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)
        at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)
        at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:330)
        at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:157)
        at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121)
        at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97)
        at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
        at java.util.concurrent.FutureTask$Sync.innerRunAndReset(Unknown Source)
        at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Unknown Source)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Unknown Source)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)
13:15:19,625 ERROR [GenericFileOnCompletion] Caused by: [java.lang.IllegalArgumentException - The separator has not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified]
java.lang.IllegalArgumentException: The separator has not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified
        at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:277)
        at org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat.unmarshal(BindyCsvDataFormat.java:123)
        at org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:56)
        at org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:50)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:299)
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:208)
        at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:125)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:80)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:299)
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:208)
        at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:269)
        at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70)
        at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89)
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68)
        at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:330)
        at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:157)
        at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121)
        at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97)
        at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
        at java.util.concurrent.FutureTask$Sync.innerRunAndReset(Unknown Source)
        at java.util.concurrent.FutureTask.runAndReset(Unknown Source)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(Unknown Source)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(Unknown Source)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)
13:15:19,625 WARN  [GenericFileOnCompletion] Rollback file strategy: org.apache.camel.component.file.strategy.GenericFileDeleteProcessStrategy@13221e4 for file: GenericFile[order.csv]
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

davsclaus
Administrator
Hi

Thanks for reporting. I have logged a ticket so we will look into if there is a bug in the source code
https://issues.apache.org/jira/browse/CAMEL-3872
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

dlin7971
This post has NOT been accepted by the mailing list yet.
Thanks,Claus Ibsen. Hope it can be fixed because camel-2.6.0 is the fininal version for the user of Spring2.5. However, not all the applications base on Spring2.5 can be updated to Spring3.0 easily.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

davsclaus
Administrator
This has been fixed in Camel 2.7. I even add your car unit test to trunk and the test passes.

I remember we fixed something about CSV delimiter in bindy, which must have been in the 2.7 release.

If you must use Camel 2.6 and JDK 1.5, then you can use the FuseSource MR 2.6 releases as we keep supporting that and backport fixes from Apache to it.
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

dlin7971
This post has NOT been accepted by the mailing list yet.
Thanks,Claus. I'm going for camel-csv instead. Although its not as good as Bindy, its still good enough to solve the issue. By the way, why camel2.7 requires spring3.0? There are still quite a lots of applicaitons base on spring2.5. update spring2.5 to spring3.0 might brings problems. What I mean is that is it possible to have some kind of adaptors for using camel 2.7 or later version in spring2.5?
zen
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

zen
In reply to this post by davsclaus
davsclaus wrote
This has been fixed in Camel 2.7. I even add your car unit test to trunk and the test passes.

I remember we fixed something about CSV delimiter in bindy, which must have been in the 2.7 release.

If you must use Camel 2.6 and JDK 1.5, then you can use the FuseSource MR 2.6 releases as we keep supporting that and backport fixes from Apache to it.
I started using bindy with camel and seeing the same error as above -
using Spring 3.1.4
all camel libs are 2.11.2

 The separator ha
s not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified
java.lang.IllegalArgumentException: The separator has not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified
        at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:296)
        at org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat.unmarshal(BindyCsvDataFormat.java:125)
        at org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:57)
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

Darwish
This post was updated on .
Hi ,

I am using 2.11.0 and suffering the same problem.

Any Updates ?

Othman Darwish
ProgressSoft Corp.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

Willem.Jiang
An unit test case could be helpful for us the dig the issue.


--  
Willem Jiang

Red Hat, Inc.
Web: http://www.redhat.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On June 18, 2014 at 9:19:05 PM, Darwish ([hidden email]) wrote:

> Hi ,
>  
> I am using 2.11.0 and suffering the same problem
>  
> Any Updates ?
>  
>  
>  
>  
>  
> -----
> Othman Darwish
> ProgressSoft Corp.
>  
> --
> View this message in context: http://camel.465427.n5.nabble.com/Camel-Bindy-problem-with-separator-tp4306927p5752503.html 
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  

Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

chrislpigg
i am using camel 2.13.2 and jboss 7.1.1 and seeing ->

java.lang.IllegalArgumentException: The separator has not been defined in the annotation @CsvRecord or not instantiated during initModel. must be specified
        at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:297) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat.unmarshal(BindyCsvDataFormat.java:138) [camel-bindy-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:67) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:111) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:60) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:166) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:423) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.component.file.remote.RemoteFileConsumer.processExchange(RemoteFileConsumer.java:99) [camel-ftp-2.13.2.jar:2.13.2]
        at org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:211) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:175) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:187) [camel-core-2.13.2.jar:2.13.2]
        at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:114) [camel-core-2.13.2.jar:2.13.2]
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [rt.jar:1.7.0_60]
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304) [rt.jar:1.7.0_60]
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) [rt.jar:1.7.0_60]
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [rt.jar:1.7.0_60]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [rt.jar:1.7.0_60]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [rt.jar:1.7.0_60]
        at java.lang.Thread.run(Thread.java:745) [rt.jar:1.7.0_60]
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel Bindy problem with separator

Ravi Godbole
Please share more details about your problem.

1. Sample record
2. How you are configuring parsing/annotations,etc.

-Ravi
Loading...