代码之家 › 专栏 › 技术社区 › sarah

Spring集成DSL添加中间流事务

spring-integration-dsl spring-dsl spring-transactions spring-integration spring-boot

sarah · 技术社区 · 8 年前

我想将流的特定部分作为事务处理。例如,我想在事务块。以下是我使用的流程代码:

@Bean
public IntegrationFlow createNumberRange() {

    return IntegrationFlows.from("npEventPubSubChannel")

            .transform(...) 
            .transform(...)// should be transactional with above transform together
            .transform(...) // non transactional
            .handle((payload, headers) -> numbRepository.saveAll(payload))
            .get();

}

我发现了一种解决方法,即添加另一个句柄并将流定向到事务网关,如下所示:

.handle("transactionalBean", "transactionalMetod") //Then implemented messagingGateway which consists of transactional method.

我还发现 mid flow transactional support 但是找不到一个例子。

1 回复 | 直到 8 年前

Artem Bilan 8 年前

如果您想在事务中封装两个转换器,除非将该调用隐藏在事务网关之后,否则您别无选择。这与使用原始Java时完全相似:

@Transactional
void myTransactionalMethod() {
    transform1();
    transform2();
}

我相信你同意我的观点,我们总是要这样做,才能让他们都在同一笔交易中。

.gateway(f -> f
            .transform(...)
            .transform(...),
        e -> e.transactional())

推荐文章

kiran reddy · split&aggregate flow中的Spring集成验证

8 年前

ahelix · 在Spring集成中为ContentEnricher定义异常回退行为

8 年前

Shah · Kafka-Spring集成流上的空指针

8 年前

heuts · 使用Spring集成优化rabbitmq的消费消息

8 年前

sarah · Spring集成DSL添加中间流事务

8 年前

rellocs wood · 如何将自定义方法添加到spring集成ftp网关接口?

8 年前

ptomli · Spring集成DSL等效于<int:gateway…/>

8 年前

Sergio Sánchez Sánchez · 如何在Spring集成Java DSL中定制消息聚合逻辑

8 年前

KJQ · Spring集成使用和方法验证

9 年前