Hi! Sorry you're having issues. BTW which version are you using? (Trunk from subversion?). Also how are you running the example?
On 8/8/07, jameszhang <[EMAIL PROTECTED]> wrote: > > I have post the problem here. > http://cwiki.apache.org/confluence/display/CAMEL/ETL+Example > http://cwiki.apache.org/confluence/display/CAMEL/ETL+Example > > Maybe we should delete that comment.thank you. > > > When I run the example,the result is failed. > > [EMAIL PROTECTED] ScheduledPollConsumer DEBUG > Starting to poll > [EMAIL PROTECTED] FileConsumer DEBUG > Polling directory src\data > [EMAIL PROTECTED] FileEndpoint DEBUG > Endpoint[file:src/data?noop=true] using strategy: > [EMAIL PROTECTED] > [EMAIL PROTECTED] FileConsumer DEBUG About > to process file: src\data\row1.xml using exchange: Exchange[FileMessage: > src\data\row1.xml] > [EMAIL PROTECTED] ScheduledPollConsumer DEBUG > Starting to poll > [EMAIL PROTECTED] DeadLetterChannel ERROR On > delivery attempt: 0 caught: java.lang.ClassCastException: > org.apache.camel.impl.DefaultExchange > java.lang.ClassCastException: org.apache.camel.impl.DefaultExchange > at > org.apache.camel.component.file.FileMessage.getExchange(FileMessage.java:51) > at > org.apache.camel.component.file.FileMessage.getExchange(FileMessage.java:33) > at > org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:49) > at > org.apache.camel.component.jpa.JpaEndpoint$1.evaluate(JpaEndpoint.java:197) > at > org.apache.camel.component.jpa.JpaProducer.process(JpaProducer.java:44) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:69) > at > org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:77) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:57) > at > org.apache.camel.component.file.FileConsumer.pollFile(FileConsumer.java:77) > at > org.apache.camel.component.file.FileConsumer.pollFileOrDirectory(FileConsumer.java:50) > at > org.apache.camel.component.file.FileConsumer.pollFileOrDirectory(FileConsumer.java:57) > at > org.apache.camel.component.file.FileConsumer.poll(FileConsumer.java:44) > at > org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:63) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:417) > at > java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:280) > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:135) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:65) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:142) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:166) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) > at java.lang.Thread.run(Thread.java:595) > > I have run the following testcase,and the result is failed too. > > package org.apache.camel.component.file; > > import java.io.File; > > import org.apache.camel.ContextTestSupport; > import org.apache.camel.Exchange; > > public class FileExchangeTest extends ContextTestSupport { > > public void testCopy() { > > File file = new > File(FileExchangeTest.class.getResource("FileExchangeTest.class").getFile()); > FileExchange fileExchange = new FileExchange(context,file); > Exchange exchange = fileExchange.copy(); > assertTrue("the copy of a FileExchange is not a FileExchange > instance", > > exchange instanceof FileExchange); > } > > } > > Thanks very much. > > -- > View this message in context: > http://www.nabble.com/Problem-with-ETL-example-tf4235477s2354.html#a12050655 > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- James ------- http://macstrac.blogspot.com/
