java - 如何使用 Camel OnException将自定义对象发布到DLQ队列

我有类似以下内容：

    onException(Exception.class)
        .maximumRedeliveries(2).redeliveryDelay(1000L).asyncDelayedRedelivery()
        .log(LoggingLevel.ERROR, LOGGER, "Body before process ->> \"${body}\" for the cause of ->  \"${exception.message}\"")
        .process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                JSONObject obj = new JSONObject();
                obj.put("body", exchange.getIn().getBody());
                obj.put("errMsg", "testErrorMsg");
                exchange.getIn().setBody(obj);
            }
        })
        .log(LoggingLevel.ERROR, LOGGER, "Body after process ->> \"${body}\" for the cause of ->  \"${exception.message}\"")
        .setExchangePattern(ExchangePattern.InOnly).setFaultBody(constant(true))
        .setHeader(RabbitMQConstants.REQUEUE, constant(Boolean.FALSE)).handled(false);

原始信息：

{"key" : "123" }

并且我期望发送到DLQ时出现以下自定义消息：

{
  "body": {
    "key": "123"
  },
  "errMsg": "testErrorMsg"
}

在日志中，我可以看到正文已按照我的期望进行了转换，但是在DLQ队列中，它显示了原始消息。

是否可以在发送到DLQ之前修改消息？

最佳答案

欢迎来到StackOverflow！
您可以使用Deal Letter Channel EIP及其onPrepareFailure添加自定义Processor，在将Exchange传递到DLQ之前对其进行修改。

关于java - 如何使用 Camel OnException将自定义对象发布到DLQ队列，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/60321015/