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

Question

如何处理 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
   }
}

Answer 1

为此，

我们提供了一个建议链，将其注入到该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

尝试的最佳方式...捕获语义与ExpressionEvaluatingRequestHandlerAdvice.请参阅文档中的描述以及JavaDocs。