亲爱的Spring社区，

我很高兴地宣布，Spring Integration 的 Java DSL 1.2 GA 版本现已发布。

伪影 org.springframework.integration:spring-integration-java-dsl:1.2.0.RELEASE 可在 Release repo 和 Maven Central 中找到。

自上一篇 Release Candidate 1 文章以来，我们收到了一些反馈，并添加了以下附加功能：

线程屏障支持

在 IntegrationFlow 定义中添加了新的 EIP 方法 .barrier() 及其镜像 .trigger()。

private static final String BARRIER = "barrier";

@Bean
public IntegrationFlow barrierFlow() {
    return f -> f
        .barrier(10000, b -> b
                .correlationStrategy(
                         new HeaderAttributeCorrelationStrategy(BARRIER))
                 .outputProcessor(g ->
                         g.getMessages()
                                 .stream()
                                 .skip(1)
                                 .findFirst()
                                 .get()))
         .channel(c -> c.queue("barrierResults"));
}

@Bean
public IntegrationFlow releaseBarrierFlow(
                          MessageTriggerAction barrierTriggerAction) {
    return IntegrationFlows.from((Channels c) -> c.queue("releaseChannel"))
        .trigger(barrierTriggerAction,
            e -> e.poller(p -> p.fixedDelay(100)))
        .get();
}

Poller errorChannel

在升级到 Spring Integration 4.3.4 后，添加了更方便的 PollerSpec.errorChannel(String)。现在我们可以在 Poller 定义中只指定 errorChannel 的 bean 名称，它将在第一次发送 ErrorMessage 时被解析。

FileSplitter 改进

SplitterEndpointSpec 现在提供了一个 delimiters() 选项，该选项映射到 DefaultMessageSplitter.setDelimiters()。

您可以在宣布先前 Milestone 版本的博客文章中找到版本 1.2 中引入的所有功能：

• Milestone 1

• Milestone 2

• Release Candidate 1

下一步

Spring Integration Java DSL 项目将迁移到 Spring Integration Core 5.0 和 Java 8 代码库。版本 1.2.x 将继续支持 bug 修复。

非常感谢社区中所有提供反馈的成员。没有你们，我们就无法拥有如此全面优秀的产品！

项目主页 | 文档 | 问题 | 帮助 | 聊天