Spring集成：如何调整所有传出错误消息

Question

我需要调整返回到集成流调用方的所有错误消息，以便不泄漏信息，无论它们是作为异常抛出还是作为异步错误处理。我希望避免在每个消息处理程序上定义自定义错误通道。我尝试将转换器连接到默认错误通道，但未成功：

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

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

Answer 1

根据您的逻辑，看起来您处理的是REST-请求/回复。因此，您需要向请求点返回回复。这可以通过请求消息的副本通道标头获得。您可以在ErrorMessage中有效负载的MessagingException.failedMessage属性中访问此类信息。

总结所有这些，您的.变换（）必须期望MessagingException作为有效负载，并通过从该失败消息复制标头来生成输出消息。这样，消息将被发送到HTTP入站网关请求消息的回复通道。