如何在 DLQ 中自定义标头消息异常

Question

我想在死信队列中自定义异常消息或添加带有自定义异常消息的新标头参数。

现在我在死信队列消息的标题中得到了原始堆栈跟踪

@StreamListener(Sink.INPUT)
public void consumer(Message<Content> message) {
    myService.update(message.getPayload().getData().getId());
}

messageInputChannel:
    consumer:
        enableDlq: true
        dlqName: error.message
        backOffInitialInterval: 15000 # the interval is 15s between each time retrying
        backOffMaxInterval: 30000 # the max interval is not over 30s between each time retrying
        maxAttempts: 3
        headerMode: raw

Answer 1

您的问题不清楚；使用 RabbitMQ binder，您可以设置 republishToDlq 以获取添加到消息中的异常信息。

见the documentation。

republishToDlq

默认情况下，重试次数用尽后失败的消息将被拒绝。如果配置了死信队列 (DLQ)，RabbitMQ 会将失败的消息（未更改）路由到 DLQ。如果设置为 true，则绑定器将失败的消息重新发布到 DLQ，并带有其他标头，包括异常消息和最终失败原因的堆栈跟踪。另请参阅 frameMaxHeadroom 属性。

默认值：假

使用Kafka binder，异常信息总是添加到headers中的死信记录中；目前没有自定义该信息的机制。