Problem with FileEndpoint

Christian Schneider Sun, 12 Oct 2008 02:51:45 -0700

Hi,

I have a problem with FileEndpoint and invalid messages. I am readingxml messages from a directory, unmarshal them and process them in abean. When the message is valid all works.


When the message is invalid I get the following warning:

Could not rename file from: c:\cameltest\in\shiporder_error.xml toc:\cameltest\ok\shiporder_error.xml

So the message appears in the error dir but does not disappear in the indir. It seems like the file is still open in camel. There are twoproblems with this.


Any ideas?

Greetings

Christian


But when the message

Here is my setup:
package jaxb;

import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.DeadLetterChannelBuilder;
import org.apache.camel.builder.ErrorHandlerBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.converter.jaxb.JaxbDataFormat;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.model.ExceptionType;
import org.apache.camel.spi.RouteContext;

public class CamelTest {

   /**
    * @param args
    * @throws Exception
    */
   public static void main(String[] args) throws Exception {

CamelContext context = new DefaultCamelContext();

       RouteBuilder builder = new RouteBuilder() {

           @Override
           public void configure() throws Exception {

errorHandler(deadLetterChannel("file:c:/cameltest/error?autoCreate=true"));from("file:c:/cameltest/in?autoCreate=true&consumer.alwaysConsume=true&moveNamePrefix=c:/cameltest/ok/")

                   .bean(OrderProcessor.class);
           }

};

       context.addRoutes(builder);
       context.start();
   }

}

This is the log I get:

12.10.2008 11:48:17 org.apache.camel.impl.DefaultCamelContext <init>
INFO: JMX enabled. Using InstrumentationLifecycleStrategy.
12.10.2008 11:48:20 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. On delivery attempt: 0 caught:org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException

- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]

org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException
- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]atorg.apache.camel.converter.jaxb.FallbackTypeConverter.convertTo(FallbackTypeConverter.java:70)atorg.apache.camel.impl.converter.DefaultTypeConverter.convertTo(DefaultTypeConverter.java:71)

   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:59)
   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:50)

atorg.apache.camel.builder.ExpressionBuilder$10.evaluate(ExpressionBuilder.java:247)atorg.apache.camel.component.bean.MethodInfo$2.evaluate(MethodInfo.java:138)atorg.apache.camel.component.bean.MethodInfo.createMethodInvocation(MethodInfo.java:57)atorg.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:115)atorg.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:103)atorg.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:69)atorg.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:155)atorg.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:91)atorg.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:57)atorg.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:39)atorg.apache.camel.component.file.FileConsumer.pollFile(FileConsumer.java:128)atorg.apache.camel.component.file.FileConsumer.pollFileOrDirectory(FileConsumer.java:77)atorg.apache.camel.component.file.FileConsumer.pollFileOrDirectory(FileConsumer.java:84)atorg.apache.camel.component.file.FileConsumer.poll(FileConsumer.java:57)atorg.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:65)

   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)

atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(UnknownSource)atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(UnknownSource)atjava.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(UnknownSource)at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(UnknownSource)

   at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)
Caused by: javax.xml.bind.UnmarshalException
- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]atjavax.xml.bind.helpers.AbstractUnmarshallerImpl.createUnmarshalException(UnknownSource)atcom.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.createUnmarshalException(UnmarshallerImpl.java:506)atcom.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.unmarshal0(UnmarshallerImpl.java:215)atcom.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.unmarshal(UnmarshallerImpl.java:184)at javax.xml.bind.helpers.AbstractUnmarshallerImpl.unmarshal(UnknownSource)at javax.xml.bind.helpers.AbstractUnmarshallerImpl.unmarshal(UnknownSource)atorg.apache.camel.converter.jaxb.FallbackTypeConverter.unmarshall(FallbackTypeConverter.java:90)atorg.apache.camel.converter.jaxb.FallbackTypeConverter.convertTo(FallbackTypeConverter.java:61)

   ... 27 more

Caused by: org.xml.sax.SAXParseException: The end-tag for element type"shiporder" must end with a '>' delimiter.atcom.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(UnknownSource)atcom.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.fatalError(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLScanner.reportFatalError(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl.scanEndElement(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl$FragmentContentDriver.next(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.next(UnknownSource)atcom.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl.scanDocument(UnknownSource)atcom.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(UnknownSource)atcom.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(UnknownSource)atcom.sun.org.apache.xerces.internal.parsers.XMLParser.parse(Unknown Source)atcom.sun.org.apache.xerces.internal.parsers.AbstractSAXParser.parse(UnknownSource)atcom.sun.org.apache.xerces.internal.jaxp.SAXParserImpl$JAXPSAXParser.parse(UnknownSource)atcom.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.unmarshal0(UnmarshallerImpl.java:211)

   ... 32 more
12.10.2008 11:48:21 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. On delivery attempt: 1 caught:org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException

- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]

org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException
- with linked exception:

   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:59)
   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:50)

   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.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)
Caused by: javax.xml.bind.UnmarshalException
- with linked exception:

   ... 27 more

   ... 32 more
12.10.2008 11:48:22 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. On delivery attempt: 2 caught:org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException

- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]

org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException
- with linked exception:

   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:59)
   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:50)

   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.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)
Caused by: javax.xml.bind.UnmarshalException
- with linked exception:

   ... 27 more

   ... 32 more
12.10.2008 11:48:23 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. On delivery attempt: 3 caught:org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException

- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]

org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException
- with linked exception:

   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:59)
   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:50)

   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.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)
Caused by: javax.xml.bind.UnmarshalException
- with linked exception:

   ... 27 more

   ... 32 more
12.10.2008 11:48:24 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. On delivery attempt: 4 caught:org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException

- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]

org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException
- with linked exception:

   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:59)
   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:50)

   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.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)
Caused by: javax.xml.bind.UnmarshalException
- with linked exception:

   ... 27 more

   ... 32 more
12.10.2008 11:48:25 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. On delivery attempt: 5 caught:org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException

- with linked exception:

[org.xml.sax.SAXParseException: The end-tag for element type "shiporder"must end with a '>' delimiter.]

org.apache.camel.RuntimeCamelException: javax.xml.bind.UnmarshalException
- with linked exception:

   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:59)
   at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:50)

   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.ThreadPoolExecutor$Worker.run(Unknown Source)
   at java.lang.Thread.run(Unknown Source)
Caused by: javax.xml.bind.UnmarshalException
- with linked exception:

   ... 27 more

   ... 32 more

12.10.2008 11:48:25org.apache.camel.component.file.strategy.RenameFileProcessStrategy commitWARNUNG: Could not rename file from: c:\cameltest\in\shiporder_error.xmlto c:\cameltest\ok\shiporder_error.xml

12.10.2008 11:48:25 org.apache.camel.processor.Logger log

SCHWERWIEGEND: Failed delivery for exchangeId:ID-notebookchris/50019-1223804899162/0-0. Handled by the failureprocessor: sendTo(Endpoint[file:c:/cameltest/error?autoCreate=true])


--

Christian Schneider
---
http://www.liquid-reality.de

Problem with FileEndpoint

Reply via email to