尊敬的 Spring 社区：

我很高兴地宣布用于 Spring Integration 的 Java DSL 1.2 GA 现已可用。

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

自上次候选版本 1 以来，我们收到了一些反馈，并添加了以下附加功能

线程屏障支持

一个新的 .barrier() 及其镜像 .trigger() EIP 方法已添加到 IntegrationFlow 定义中

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();
}

轮询器 errorChannel

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

FileSplitter 改进

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

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

• 里程碑 1

• 里程碑 2

• 候选版本 1

后续步骤

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

非常感谢社区中每个提供反馈的人。 没有你们，我们就不会有如此好的综合产品！

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