时间戳

首页 > 解决方案 > 如何为spring集成流添加try catch异常以实现嵌套事务

spring-integration - 如何为spring集成流添加try catch异常以实现嵌套事务

问题描述

如何在 Spring 集成流程中处理嵌套事务。基本上我有一个从数据库中获取所有订单并按订单处理的进程，如果在单个订单上抛出异常，所有处理的订单都会回滚。

    IntegrationFlows.from("perOrder")
         .filter(Order.class, order -> order.getItems().size() > 0)
         .handle(orderHandler, "handle") /*someway i way want to add try/catch for this method here so that 
if handle method throws exception, want to suppress for that order and mark as failure only for that order */
         .get();

public class OrderHandler {
   @Transactional(propagation = Propagation.NESTED)
   public handle() {
      processing code 
      throw exception in case of any validation failure
   }
}

标签： spring-integrationspring-integration-dsl

解决方案

为此，我们提供了一个adviceChain来注入到 that 的端点handle()：

.handle((GenericHandler<?>) (p, h) -> {
                    throw new RuntimeException("intentional");
                }, e -> e.advice(retryAdvice()))

您可以在那里注入任何可用的Advice实现：https ://docs.spring.io/spring-integration/docs/current/reference/html/#message-handler-advice-chain ，包括TransactionInterceptor：https ://docs.spring.io /spring-integration/docs/current/reference/html/#tx-handle-message-advice

拥有try...catch语义的最好方法是使用ExpressionEvaluatingRequestHandlerAdvice. 请参阅 Docs 及其 JavaDocs 中的描述。

推荐阅读