Hi Charles. Am not returning anything explicitly though. Am trying to send the java objects returned by Bindy to a seda/direct endpoint ..
Can u help me in adjusting the code to make it work? Any ideas would be helpful . Cheers Reji On 06/04/2014 5:40 pm, "Charles Moulliard-2 [via Camel]" < [email protected]> wrote: > 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 <[hidden > email]<http://user/SendEmail.jtp?type=node&node=5749857&i=0>> > 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 > > > ------------------------------ > If you reply to this email, your message will be added to the discussion > below: > > http://camel.465427.n5.nabble.com/ReturnType-of-Bindy-CSV-to-JAva-Obj-tp5749842p5749857.html > To unsubscribe from ReturnType of Bindy - CSV to JAva Obj, click > here<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5749842&code=Y29udGFjdHJlamlAZ21haWwuY29tfDU3NDk4NDJ8MTAwNDkxODIzMw==> > . > NAML<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > -- View this message in context: http://camel.465427.n5.nabble.com/ReturnType-of-Bindy-CSV-to-JAva-Obj-tp5749842p5749858.html Sent from the Camel - Users mailing list archive at Nabble.com.
