Apache Camel - проблема с обработкой ошибок - PullRequest
Новая
       6

Apache Camel - проблема с обработкой ошибок

1 голос
/ 22 сентября 2011

У меня проблема с обработкой ошибок.Если в jrnRoute возникает исключение, оно обрабатывается процессором exceptionHandler.Хорошо.Но сообщение, вызвавшее исключение, все еще остается в jrnQueue, обрабатывается снова и вызывает ошибку снова и снова.Также у меня есть предупреждение (см. Ниже) в логах.Как остановить бесконечную повторную доставку?Я хочу выбросить сообщение в случае ошибки.

Camel configuration 

    <camel:onException>
        <camel:exception>java.lang.Exception</camel:exception>
        <camel:redeliveryPolicy disableRedelivery="true" />
        <camel:process ref="exceptionHandler" />
        <camel:rollback markRollbackOnly="true" />
    </camel:onException>

    <camel:route id="translatorRoute">
        <camel:from ref="transactionsQueue" />
        <camel:process ref="messageTranslator" />
        <camel:inOnly ref="apfRequestQueue" />
    </camel:route>
    <camel:route id="jrnRoute">
        <camel:from ref="jrnQueue" />
        <camel:process ref="jrnProcessor" />
        <camel:stop />
    </camel:route>
</camel:camelContext>

Warning

11:15:00,141 WARN  [JmsMessageListenerContainer] Execution of JMS message listener failed, and no ErrorHandler has been set.
org.apache.camel.RuntimeCamelException: org.apache.camel.RollbackExchangeException: Intended rollback. Exchange[JmsMessage: [ObjectMessageImpl com.swiftmq.jms.ObjectMessageImpl@c84d9d
messageIndex = 5_2
messageId = [LazyUTF8String, s=ID:/172.26.214.11/5349789614428334512/10/0, buffer=[B@5f7fd8]
userId = [LazyUTF8String, s=null, buffer=[B@1c254aa]
clientId = null
timeStamp = 1316682898526
correlationId = null
replyTo = null
destination = jrnQueue@z4smq_4001
deliveryMode = 2
redelivered = true
deliveryCount = 8
type = null
expiration = 0
priority = 4
props = {...}
readOnly = true
sourceRouter = null
destRouter = null
destQueue = null array=[B@1447e6b cnt=1295]]
    at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1145)
    at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:108)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:243)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
Caused by: org.apache.camel.RollbackExchangeException: Intended rollback. Exchange[JmsMessage: [ObjectMessageImpl com.swiftmq.jms.ObjectMessageImpl@c84d9d
messageIndex = 5_2
messageId = [LazyUTF8String, s=ID:/172.26.214.11/5349789614428334512/10/0, buffer=[B@5f7fd8]
userId = [LazyUTF8String, s=null, buffer=[B@1c254aa]
clientId = null
timeStamp = 1316682898526
correlationId = null
replyTo = null
destination = jrnQueue@z4smq_4001
deliveryMode = 2
redelivered = true
deliveryCount = 8
type = null
expiration = 0
priority = 4
props = {...}
readOnly = true
sourceRouter = null
destRouter = null
destQueue = null array=[B@1447e6b cnt=1295]]

Ответы [ 2 ]

3 голосов
/ 23 сентября 2011

Да, markRollbackOnly приведет к тому, что менеджер транзакций пометит TX как откат, и, следовательно, JMS-брокер сохранит сообщение в очереди и повторно доставит его снова.Так что удалите это вместо этого.

И сделай так, как Бен написал выше, с обработанной истиной: 

 <camel:onException>
        <camel:exception>java.lang.Exception</camel:exception>
        <camel:redeliveryPolicy disableRedelivery="true" />
        <camel:handled>
            <camel:constant>true</camel:constant>
        </camel:handled>

        <camel:process ref="exceptionHandler" />
 </camel:onException>
2 голосов
/ 22 сентября 2011

похоже, что markRollbackOnly="true" - это проблема ...

Обычно я делаю что-то подобное, чтобы просто обработать (предотвратить передачу обратно вызывающей стороне), предотвратить повторные попытки и зарегистрировать сообщения об ошибках ... 

onException(Exception.class)
    .handled(true).maximumRedeliveries(0)
    .to("log:error processing message");
...