新闻 Java DSL for Spring Integration 1.2 正式版发布 下载

Java DSL for Spring Integration 1.2 正式版发布了，用于集成Spring的Java DSL。

值得关注的更新：

• 
  支持Thread Barrier
  

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
  
  
• 
  文件分割器的改进
  

点击提交记录以了解更多，点此查看发布说明

下载地址：

• 
  Source code (zip)
  
  
• 
  Source code (tar.gz)
  

Java DSL for Spring Integration 1.2 正式版发布下载地址