Java DSL for Spring Integration 1.2 Milestone 2 发布了,目前迭代更新的一些亮点: JPA support @Autowired private EntityManagerFactory entityManagerFactory; @bean public IntegrationFlow pollingAdapterFlow() { return IntegrationFlows .from(Jpa.inboundAdapter(this.entityManagerFactory) .entityClass(StudentDomain.class) .maxResults(1) .expectSingleResult(true), e -> e.poller(p -> p.trigger(new OnlyOnceTrigger()))) .channel(c -> c.queue("pollingResults")) .get(); } @bean public IntegrationFlow updatingGatewayFlow() { return f -> f .handle(Jpa.updatingGateway(this.entityManagerFactory), e -> e.transactional(true)) .channel(c -> c.queue("persistResults")); } @bean public IntegrationFlow retrievingGatewayFlow() { return f -> f .handle(Jpa.retrievingGateway(this.entityManagerFactory) .jpaQuery("from Student s where s.id = :id") .expectSingleResult(true) .parameterExpression("id", "payload")) .channel(c -> c.queue("retrieveResults")); } Mid-flow transaction support Scatter-Gather support More routers improvements 点击查看提交记录以了解更多 发行说明: https://spring.io/blog/2016/09/15/java-dsl-for-spring-integration-1-2-milestone-2-is-available 下载地址: Source code (zip) Source code (tar.gz) Java DSL for Spring Integration 1.2 Milestone 2下载地址