spring-integration - 如何将 header 信息转移到 errorChannel？

Question

在我的应用程序中，我的网关正在接收 header 中的请求标识符，每当发生错误时，错误 channel 都会收到异常。但看起来，errorChannel 不从网关获取 header 。

是否可以将 header 信息也传送到错误 channel ？

示例:
sampleErrorChannel 中的 sysout 没有我通过的 header 。

https://github.com/manojp1988/spring-integration/blob/master/javadsl/src/main/java/ErrorChannel/ErrorChannelExample.java

Answer 1

错误 channel 上的消息是 ErrorMessage ，它的有效载荷为 MessagingException它有两个属性，cause (异常(exception))和 failedMessage .

您可以通过这种方式访问​​失败的消息标题。

例如payload.failedMessage.headers['foo']使用 SpEL 时。

如果在错误流上使用 POJO 服务激活器，则可以使用

public void failure(MessagingException failure) {
    MyHeader mh = failure.getFailedMessage().getHeader("mh");
}