使用特定于路由的DLQ配置Java/CAMEL/AMQ

Question

这里是Java 8/Camel 2.19.x/AMQ 5.15.x。

我有一个Java应用程序，它使用Camel来使用AMQ队列中的消息，处理这些消息，并处理这些消息。有时路由的输出是将处理结果备份到另一个队列中，以供进一步的下游处理，但并不总是/必须。典型的Java/CAMEL/AMQ设置。

我的每条路由（我使用的是Camel XML DSL）都有一个配置的 处理程序，通常如下所示：

<onException useOriginalMessage="true">
  <exception>java.lang.Exception</exception>

  <redeliveryPolicy logStackTrace="true"/>

  <handled>
    <constant>true</constant>
  </handled>

  <log message="${exception.stacktrace}" loggingLevel="ERROR"/>

  <rollback markRollbackOnly="true"/>

</onException>

非常简单：记录异常并回滚。

也就是说，如果我的应用程序有30条路由，每条路由都从30个不同的AMQ队列中消耗，那么我将有30个不同的“DLQ”，它们各自的 处理程序将向其中发送失败消息。

理想情况下，我希望该配置位于AMQ端（也可能位于activem.xml或类似内容的内部），这样，如果需要更改DLQ目的地，我就不需要进行代码更改或重新部署。但是如果只能从Camel route/config内部执行，也可以。

我想我可以修改每条路由,使其包含原始消息的自定义目的地DLQ：

<onException useOriginalMessage="true">
  <exception>java.lang.Exception</exception>

  <redeliveryPolicy logStackTrace="true"/>

  <handled>
    <constant>true</constant>
  </handled>

  <log message="${exception.stacktrace}" loggingLevel="ERROR"/>

  <rollback markRollbackOnly="true"/>

  <to uri="activemq:fizzbuzz.dlq"/>

</onException>

但我希望有比这更优雅的东西...

有什么办法让我这么做吗？

Answer 1

也许这样对你会更好：

             DeadLetterChannelBuilder errorHandlerBuilder = deadLetterChannel("jms:dummy");
    errorHandlerBuilder.onPrepareFailure(exchange -> {
        exchange.getIn().setHeader("CamelJmsDestinationName",exchange.getIn().getHeader("JMSDestination",String.class).concat(".DLQ"));
    });

    from("jms:input1")
            .to("seda:process");

    from("jms:input2")
            .to("seda:process");

    from("jms:input3")
            .to("seda:process");

    from("seda:process").errorHandler(errorHandlerBuilder)
            .process(exchange -> {
                throw new RuntimeException();
            });

您可以在运行时计算DLQ队列名称。DeadLetterChannelBuilder也可以像onException一样进行配置。