Java DSL for Spring Integration 1.2 正式版发布了，用于集成Spring的Java DSL。
值得关注的更新：
支持Thread Barrier[code]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();
}[/code]Poller
文件分割器的改进
软件详情：https://github.com/spring-projects/spring-integration-java-dsl/compare/v1.2.0.RELEASE...master
下载地址：https://github.com/spring-projects/spring-integration-java-dsl/archive/v1.2.0.RELEASE.zip
来自:开源中国社区
