I don't see in the camel examples that you call your processor. Anyway,
your error is related to the fact that wrong type returned by a processor
that you call.
On Sat, Apr 5, 2014 at 1:57 PM, contactreji <contactr...@gmail.com> wrote:
> Hey Guys
>
> I was creating a POC which reads a CSV file with following content
>
> *reji,mathews,2681,pass
> jack,rose,261,fail
> *
> The class defined is as follows
> *
> package com.poc.camel.csv.java.bindy;
>
> import java.io.Serializable;
>
> import javax.xml.bind.annotation.XmlRootElement;
> import org.apache.camel.dataformat.bindy.annotation.CsvRecord;
> import org.apache.camel.dataformat.bindy.annotation.DataField;
>
> @XmlRootElement
> @CsvRecord(separator = ",",crlf="WINDOWS",generateHeaderColumns=false)
> public class Result implements Serializable{
>
> @DataField(pos = 1)
> private String firstName;
>
> @DataField(pos = 2)
> private String lastName;
>
> @DataField(pos = 3)
> private String rollNo;
>
> @DataField(pos = 4)
> private String result;
>
> public String getFirstName() {
> return firstName;
> }
>
> public void setFirstName(String firstName) {
> this.firstName = firstName;
> }
>
> public String getLastName() {
> return lastName;
> }
>
> public void setLastName(String lastName) {
> this.lastName = lastName;
> }
>
> public String getRollNo() {
> return rollNo;
> }
>
> public void setRollNo(String rollNo) {
> this.rollNo = rollNo;
> }
>
> public String getResult() {
> return result;
> }
>
> public void setResult(String result) {
> this.result = result;
> }
>
> }
>
> *
>
> My CAMEL Route file looks like
>
> *
> <bean id="bindyDataformat"
>
> class="org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat">
> <constructor-arg value="com.poc.camel.csv.java.bindy" />
> </bean>
>
> <bean id="csv"
> class="com.poc.camel.csv.java.bindy.HandleOrderBean" />
>
> <camelContext xmlns="http://camel.apache.org/schema/spring";>
>
> <dataFormats>
> <jaxb id="myJaxb" prettyPrint="true"
> contextPath="com.poc.camel.csv.java.bindy" />
> </dataFormats>
>
>
>
>
> <route streamCache="true">
> <from uri="file://C:/Users/Mathews/Desktop/in" />
> <unmarshal ref="bindyDataformat" />
> <to uri="bean:csv" />
>
> </route>
>
> <route>
> <from uri="seda:queue:in" />
> <to uri="log:reached route 2"/>
> <marshal ref="myJaxb" />
> <to uri="file://C:/Users/Mathews/Desktop/out" />
> </route>
>
> </camelContext>
>
> </beans>
> *
>
> And my Java Processor looks like follows
> *
> package com.poc.camel.csv.java.bindy;
>
> import java.util.ArrayList;
> import java.util.List;
>
> import org.apache.camel.impl.DefaultCamelContext;
> import org.apache.camel.impl.DefaultProducerTemplate;
>
> import org.apache.camel.CamelContext;
> import org.apache.camel.Exchange;
> import org.apache.camel.Processor;
> import org.apache.camel.ProducerTemplate;
>
> public class HandleOrderBean implements Processor {
>
> @SuppressWarnings("unchecked")
> @Override
> public void process(Exchange exchange) throws Exception {
> // TODO Auto-generated method stub
>
> CamelContext context = new DefaultCamelContext();
> ProducerTemplate template =
> context.createProducerTemplate();
> Result result = new Result();
> List<Result> listofResults = new ArrayList<Result>();
> listofResults = exchange.getIn().getBody(ArrayList.class);
> for (int i = 0; i < listofResults.size(); i++) {
> result = listofResults.get(i);
>
> // send to a specific queue
> template.sendBody("seda:queue:in", result);
>
> }
>
> }
>
> }
> *
>
>
> But I get following error
> *
> [pache.camel.spring.Main.main()] DefaultStreamCachingStrategy INFO
> StreamCaching in use with spool directory:
>
> C:\Users\Mathews\AppData\Local\Temp\camel\camel-tmp-127025a0-28cb-44a3-9b80-be5cc749ee46
> and rules: [Spool > 128K body size]
> [pache.camel.spring.Main.main()] JaxbDataFormat INFO
> Creating JAXBContext with contextPath: com.poc.camel.csv.java.bindy and
> ApplicationContextClassLoader: java.net.URLClassLoader@90b96e
> [pache.camel.spring.Main.main()] SpringCamelContext INFO
> Route:
> route1 started and consuming from:
> Endpoint[file://C:/Users/Mathews/Desktop/in]
> [pache.camel.spring.Main.main()] SpringCamelContext INFO
> Route:
> route2 started and consuming from: Endpoint[seda://queue:in]
> [pache.camel.spring.Main.main()] SpringCamelContext INFO Total
> 2 routes, of which 2 is started.
> [pache.camel.spring.Main.main()] SpringCamelContext INFO
> Apache
> Camel 2.12.2 (CamelContext: camel-1) started in 1.331 seconds
> [://C:/Users/Mathews/Desktop/in] DefaultErrorHandler ERROR
> Failed
> delivery for (MessageId: ID-REJI-PC-49519-1396698959426-0-1 on ExchangeId:
> ID-REJI-PC-49519-1396698959426-0-2). Exhausted after delivery attempt: 1
> caught: java.lang.ClassCastException: java.util.HashMap cannot be cast to
> com.poc.camel.csv.java.bindy.Result
>
> Message History
>
> ---------------------------------------------------------------------------------------------------------------------------------------
> RouteId ProcessorId Processor
> Elapsed (ms)
> [route1 ] [route1 ]
> [file://C:/Users/Mathews/Desktop/in
> ] [ 130]
> [route1 ] [unmarshal1 ] [unmarshal[ref:bindyDataformat]
> ] [ 83]
> [route1 ] [to1 ] [bean:csv
> ] [ 32]
>
> Exchange
>
> ---------------------------------------------------------------------------------------------------------------------------------------
> Exchange[
> Id ID-REJI-PC-49519-1396698959426-0-2
> ExchangePattern InOnly
> Headers
> {breadcrumbId=ID-REJI-PC-49519-1396698959426-0-1,
> CamelFileAbsolute=true,
> CamelFileAbsolutePath=C:\Users\Mathews\Desktop\in\test.txt,
> CamelFileLastModified=1396688098196, CamelFileLength=50,
> CamelFileName=test.txt, CamelFileNameConsumed=test.txt,
> CamelFileNameOnly=test.txt, CamelFileParent=C:\Users\Mathews\Desktop\in,
> CamelFilePath=C:\Users\Mathews\Desktop\in\test.txt,
> CamelFileRelativePath=test.txt, CamelRedelivered=false,
> CamelRedeliveryCounter=0}
> BodyType java.util.ArrayList
> Body
>
> [{com.poc.camel.csv.java.bindy.Result=com.poc.camel.csv.java.bindy.Result@3a4f1
> },
>
> {com.poc.camel.csv.java.bindy.Result=com.poc.camel.csv.java.bindy.Result@141f75b
> }]
> ]
>
> Stacktrace
>
> ---------------------------------------------------------------------------------------------------------------------------------------
> java.lang.ClassCastException: java.util.HashMap cannot be cast to
> com.poc.camel.csv.java.bindy.Result
> at
>
> com.poc.camel.csv.java.bindy.HandleOrderBean.process(HandleOrderBean.java:27)[file:/C:/Users/Mathews/workspace/camel-csv-java-bindy/target/classes/:]
> at
>
> org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:97)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:67)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:103)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.processor.Pipeline.process(Pipeline.java:118)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:401)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:201)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:165)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:187)[camel-core-2.12.2.jar:2.12.2]
> at
>
> org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:114)[camel-core-2.12.2.jar:2.12.2]
> at java.util.concurrent.Executors$RunnableAdapter.call(Unknown
> Source)[:1.7.0_45]
> at java.util.concurrent.FutureTask.runAndReset(Unknown
> Source)[:1.7.0_45]
> at
>
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown
> Source)[:1.7.0_45]
> at
>
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
> Source)[:1.7.0_45]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
> Source)[:1.7.0_45]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
> Source)[:1.7.0_45]
> at java.lang.Thread.run(Unknown Source)[:1.7.0_45]
> [://C:/Users/Mathews/Desktop/in] GenericFileOnCompletion WARN
> Rollback file strategy:
>
> org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@4729ca
> for file: GenericFile[C:\Users\Mathews\Desktop\in\test.txt]
> [://C:/Users/Mathews/Desktop/in] DefaultErrorHandler ERROR
> Failed
> delivery for (MessageId: ID-REJI-PC-49519-1396698959426-0-3 on ExchangeId:
> ID-REJI-PC-49519-1396698959426-0-4). Exhausted after delivery attempt: 1
> caught: java.lang.ClassCastException: java.util.HashMap cannot be cast to
> com.poc.camel.csv.java.bindy.Result
>
> Message History
>
> ---------------------------------------------------------------------------------------------------------------------------------------
> RouteId ProcessorId Processor
> Elapsed (ms)
> [route1 ] [route1 ]
> [file://C:/Users/Mathews/Desktop/in
> ] [ 3]
> [route1 ] [unmarshal1 ] [unmarshal[ref:bindyDataformat]
> ] [ 2]
> [route1 ] [to1 ] [bean:csv
> ] [ 1]
>
> Exchange
>
> ---------------------------------------------------------------------------------------------------------------------------------------
> Exchange[
> Id ID-REJI-PC-49519-1396698959426-0-4
> ExchangePattern InOnly
> Headers
> {breadcrumbId=ID-REJI-PC-49519-1396698959426-0-3,
> CamelFileAbsolute=true,
> CamelFileAbsolutePath=C:\Users\Mathews\Desktop\in\test.txt,
> CamelFileLastModified=1396688098196, CamelFileLength=50,
> CamelFileName=test.txt, CamelFileNameConsumed=test.txt,
> CamelFileNameOnly=test.txt, CamelFileParent=C:\Users\Mathews\Desktop\in,
> CamelFilePath=C:\Users\Mathews\Desktop\in\test.txt,
> CamelFileRelativePath=test.txt, CamelRedelivered=false,
> CamelRedeliveryCounter=0}
> BodyType java.util.ArrayList
> Body
>
> [{com.poc.camel.csv.java.bindy.Result=com.poc.camel.csv.java.bindy.Result@33827c
> },
>
> {com.poc.camel.csv.java.bindy.Result=com.poc.camel.csv.java.bindy.Result@1bba333
> }]
> ]
>
> *
>
>
> Can you help with this? Basically I am trying to create a java obj using
> CSV
> data and later trying to print them as XML data.
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/ReturnType-of-Bindy-CSV-to-JAva-Obj-tp5749842.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
Charles Moulliard
Apache Committer / Architect @RedHat
Twitter : @cmoulliard | Blog : http://cmoulliard.github.io
