9

我有一条骆驼路线，在卡拉夫内运行，为此我添加了一个死信频道。这是为了处理路由失败的情况，我想保留问题消息并记录原因。由于我正在异步处理一些处理，因此我无法将异常抛出回调用应用程序。

通过阅读文档并尝试了许多案例，我不清楚如何将异常记录到 Karaf 的日志中并将原始消息存入死信队列。

这是我所拥有的摘录：-

<bean id="deadLetterQueue" class="org.apache.camel.builder.DeadLetterChannelBuilder">
    <property name="deadLetterUri" value="activemq:dead.letter.queue"/>
    <property name="redeliveryPolicy" ref="redeliveryPolicy"/>
</bean>

<bean id="redeliveryPolicy" class="org.apache.camel.processor.RedeliveryPolicy">
    <property name="maximumRedeliveries" value="1"/>
    <property name="redeliveryDelay" value="1000"/>
</bean>

<camelContext id="notification" errorHandlerRef="deadLetterQueue"
    trace="false" xmlns="http://camel.apache.org/schema/blueprint">
    <onException>
        <exception>org.xyz.exceptions.unchecked.notificationException</exception>
        <log logName="notifications" loggingLevel="ERROR"
            message="Exception from notification Camel route" />
    </onException>

    <route id="DoSomething" errorHandlerRef="deadLetterQueue">
        <from uri="activemq:notification.in" />
        <log logName="notifications" loggingLevel="TRACE"
            message="Notification route initiated" />
        <bean ref="NotificationProcessor" method="doStuff" />
    </route>
</camelContext>

如果我删除“onException”结构，那么在所有异常情况下，源消息都会出现在死信队列中，但不会被记录。

如果我按上述方式运行它，那么异常跟踪将记录到 Karaf 的日志中（如果它是“notificationException”），但相关的源消息不会回滚到死信队列并消失在以太中（大概是因为它认为我'已经在“onException”结构中处理了它）。

在查看了不同类型的错误处理程序之后，我尝试向 DeadLetterChannelBuilder 添加一些东西，例如......

<property name="logName" value="notifications"/>
<property name="level" value="ERROR"/>

...但这些不是合法财产。

让我感到震惊的是，必须在 onException 子句中明确列出不同的异常是不正确的。

那么，如何让死信通道记录异常跟踪以及将消息放入队列？也许死信通道不是正确的处理程序——在这种情况下，我对自动重新发送并不感兴趣。

感谢您的任何指导，

J。

4

2 回答 2

7

这是记录异常并将交换发送到死信队列的另一个选项，用 Camel DSL 表示

Processor exceptionLoggingProcessor = (exchange) -> 
      logger.error("Error handled in camel.", exchange.getProperty(Exchange.EXCEPTION_CAUGHT));

setErrorHandlerBuilder(deadLetterChannel("direct:dlq")
    .onExceptionOccurred(exceptionLoggingProcessor));
于 2016-07-06T14:35:56.867 回答
6

您可以只使用死信队列的路由，并进行日志记录并发送到 JMS 队列。然后使用direct来指代这条路线

<property name="deadLetterUri" value="direct:myDLC"/>

<route>
  <from uri="direct:myDLC"/>
  <log logName="notifications" loggingLevel="ERROR"
            message="Exception from notification Camel route" />
  <to uri="activemq:dead.letter.queue"/>
</route>

你用的是什么版本的骆驼？

于 2012-12-05T08:14:10.810 回答