spring集成：入站适配器上的错误处理

Question

基础知识：

• 使用带集成的Spring 4.1.1，引导和1.0.0的DSL。
• 多个入站SFTP适配器在不同的时间表上从不同的供应商获取文件。
• 每个集成流在文件下载后将标头附加到消息中，以标识供应商源。
• 使用MessagePublishingErrorHandler处理异常。
• 标准消息流在消息处理成功或消息未能完成时通知外部监控解决方案。使用消息头来识别哪个流失败。

在我们收到消息后，成功和错误流都非常有效。但是，当我们遇到在生成消息之前发生的错误（即无法连接到sftp服务器）时，我们没有机会附加头。

我一直在查看示例和留档，我找不到一个好方法来从MessagePublishingErrorHandler产生的错误消息中附加相同的头，而不覆盖轮询器上的错误处理程序，或者为每个入站集成创建自定义错误流。这里有什么选项？

这是一个配置示例：

        IntegrationFlows
        .from(
            Sftp.inboundAdapter(sessionFactory)
                    .autoCreateLocalDirectory(true)
                    .localDirectory(configProperties.getLocalDirectory())
                    .preserveTimestamp(true)
                    .remoteDirectory(configProperties.getRemoteDirectory()),
            c -> c.poller(Pollers
                    .fixedRate(properties.getSftpInterval(), properties.getSftpIntervalUnit())
                    .errorHandler(errorHandler)) // custom error handler?
        )
        .enrichHeaders(
                    MapBuilder
                            .with("vendorName", "vendor1")
                            .get()
        )
        .channel("fileChannelHandler")
        .get();

Answer 1

是的-问题是，对于轮询的通道适配器，如果在消息源中抛出异常。receive（），目前还没有任何消息可以通过自定义标题进行增强。

该框架目前不允许修改ErrorMessage本身的头（它将原始异常作为此类异常的有效负载）。

一个解决方法（除了自定义EH之外）是在每个错误流上放置一个头enricher，以识别源适配器。

将来，该框架可以在ErrorMessage中添加一个头，其中包含通道适配器的id，以便在常见错误流中识别源。

欢迎打开一个“改进”JIRA问题，我们来看看。