Hi,
Current Camel Error handler only works for the checking the error which
is thrown between the route's endpoints.
Your UTFDataFormatException is thrown when the Message is created to be
routed into the pipeline, I don't think the camel error handler can
catch this kind of error.
Maybe we need to do some enhancement on the JMSComponent to let it
create a message with exception when it create the camel message from
the JMS message, then camel error handle will check it when this message
is routing to the other endpoint.
Willem
Ensonik wrote:
Hi all,
We currently have a problem where messages that can't be read properly get
dropped instead of being put into a dlq. I have an errorHandler that works
properly when the exception is thrown from within the route (from a
processor for example), but refuses to kick in when it's a lower level error
(i.e.: Before even getting into the route).
- I'm using camel-2.0-M1
- The route is setup through the Java dsl
The route looks something like:
errorHandler(
deadLetterChannel(configuration.getDLQCompomentUrl()).
maximumRedeliveries(configuration.getMaxRedeliveries()).
log(RTSListenerRouteBuilder.class).
retriesExhaustedLogLevel(LoggingLevel.ERROR).
retryAttemptedLogLevel(LoggingLevel.TRACE)
);
from(configuration.getSourceComponentUrl()).
choice().
when(configuration.getMessageFilter()).
process(configuration.getMessageEnricher()).
to(configuration.getMessageEndpoint()).
otherwise().
to(configuration.getInvalidMessageComponentUrl());
Pretty straightforward ... I've tried adding a few variants, most notable
adding a global exception handler:
onException(java.io.UTFDataFormatException.class).handled(false).to("jms.mydlq");
To no avail.
Here's the stack trace I get:
[WARN] [org.springframework.jms.listener.DefaultMessageListenerContainer]
Execution of JMS message listener failed
org.apache.camel.RuntimeCamelException: Failed to extract body due to:
javax.jms.JMSException: java.io.UTFDataFormatException. Message:
ActiveMQTextMessage {...l}
at
org.apache.camel.component.jms.JmsBinding.extractBodyFromJms(JmsBinding.java:104)
at
org.apache.camel.component.jms.JmsMessage.createBody(JmsMessage.java:150)
at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:45)
at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:52)
at
org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:74)
at
org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:52)
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41)
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:65)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:72)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:543)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:482)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:451)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:323)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:261)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:982)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:881)
at java.lang.Thread.run(Thread.java:613)
Caused by: javax.jms.JMSException: java.io.UTFDataFormatException
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.command.ActiveMQTextMessage.getText(ActiveMQTextMessage.java:91)
at
org.apache.camel.component.jms.JmsBinding.extractBodyFromJms(JmsBinding.java:93)
... 16 more
Caused by: java.io.UTFDataFormatException
at
org.apache.activemq.util.MarshallingSupport.readUTF8(MarshallingSupport.java:372)
at
org.apache.activemq.command.ActiveMQTextMessage.getText(ActiveMQTextMessage.java:86)
... 17 more
Thanks for any input.
