error-handling - Spring集成: how to adjust all outgoing error messages

Question

我需要调整返回给我的集成流调用者的所有错误消息，这样我就不会泄漏信息，无论它们是作为异常抛出还是作为异步错误处理。我想避免在每个消息处理程序上定义自定义错误 channel 。
我试图将变压器附加到默认错误 channel 但没有成功:

@Bean
IntegrationFlow errorFlow() {
    return IntegrationFlows.from("errorChannel")
            .transform("{'status': 500, 'error': 'Internal Server Error'}")
            .get();
}

是否有一个中心点可以转换所有传出的错误消息？

Answer 1

根据您的逻辑，您似乎在处理 REST - 请求/回复。因此，您需要向请求点返回回复。可通过 replyChannel 获得请求消息的 header 。您可以在 MessagingException.failedMessage 中访问此类信息payload 的属性(property)在 ErrorMessage .

总结所有你的.transform()必须期待 MessagingException作为有效负载并生成输出消息，并从该 failedMessage 复制 header .这样消息将被发送到 HTTP Inbound Gateway 请求消息的回复 channel 。