Spring Integration.消息驱动信道适配器.变压器错误处理，原始消息

Question

我在处理spring集成流中的错误时遇到了一个问题。流程的工作方式如下：我的入口点是消息驱动的通道适配器->路由器->过滤器->转换器->服务激活器->数据库。我已经使用自定义消息侦听器容器编写了自己的错误处理程序，它的工作方式与预期一致，但是当我出现异常时，我需要将原始消息保存到数据库中。

问题是，当我从数据库中获得异常时，错误处理策略会重新使用一个MessageHandleException，但异常中的failedMessage是转换后的消息，在这种情况下，我如何获得原始消息？

谢谢你的帮助。

Answer 1

您应该在消息驱动通道适配器之后使用header-enricher:

<int:header-enricher>
   <int:header name="originalPayload" expression="payload"/>
</int:header-enricher>

并在自己的错误处理程序中使用FailedMessage中的此标头。