親愛的 Spring 社群：

我很榮幸地宣布，適用於 Spring Integration 的 Java DSL 1.2 GA 版本現已推出。

Artifact org.springframework.integration:spring-integration-java-dsl:1.2.0.RELEASE 可在 Release repo 與 Maven Central 中取得。

自上次的 Release Candidate 1 之後，我們收到了一些回饋，並新增了以下額外功能：

Thread Barrier 支援

已將新的 .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();
}

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 版本將繼續支援錯誤修正。

非常感謝社群中所有提供回饋意見的人。 沒有你們，我們就不會有這麼好的綜合產品！

專案頁面 | 文件 | 問題 | 協助 | 聊天