如何识别Spring Integration JMS出站适配器提交成功及关联TransactionSynchronizationFactory？

1. 如何识别Spring Integration JMS出站适配器的写入提交操作已成功完成？ #

• 若JMS出站适配器配置了sessionTransacted(true)，发送消息过程中未抛出异常，即可确认JMS会话的提交操作已成功完成。因为事务性会话下，JmsTemplate会在发送完成后自动提交事务（无外层事务时）。
• 也可以通过添加请求处理器增强来监听结果，比如使用ExpressionEvaluatingRequestHandlerAdvice，配置成功回调通道处理发送完成后的逻辑，以此明确确认提交状态。示例配置如下：

.handle(Jms.outboundAdapter(connectionFactory)
        .destination("outputqueue")
        .configureJmsTemplate(jmsTemplateSpec -> jmsTemplateSpec.id("jmsTemplateOutbound")
            .sessionTransacted(true)
        ),
    e -> e.advice(customSuccessAdvice()))

其中customSuccessAdvice可定义成功后的操作，比如触发后续流程或记录日志。

2. 是否可以为JMS出站适配器附加TransactionSynchronizationFactory？ #

可以，且完全匹配你的业务需求（JMS发送成功后更新数据库），具体实现步骤如下：

步骤1：自定义事务同步处理器 #

实现TransactionSynchronizationProcessor接口，在afterCommit方法中编写数据库更新逻辑，该方法会在事务提交后执行：

public class DbUpdateSynchronizationProcessor implements TransactionSynchronizationProcessor {
    @Override
    public void beforeCommit(boolean readOnly) {
        // 可选：提交前的预处理逻辑
    }

    @Override
    public void afterCommit() {
        // 执行数据库更新操作
        updateTargetDatabase();
    }

    @Override
    public void afterCompletion(int status) {
        // 可选：事务完成后的清理逻辑
    }

    // 实现其他接口默认方法
}

步骤2：配置TransactionSynchronizationFactory #

将自定义处理器注入到DefaultTransactionSynchronizationFactory中：

@Bean
public TransactionSynchronizationFactory dbUpdateSyncFactory() {
    DefaultTransactionSynchronizationFactory factory = new DefaultTransactionSynchronizationFactory();
    factory.setTransactionSynchronizationProcessor(new DbUpdateSynchronizationProcessor());
    return factory;
}

步骤3：绑定到JMS出站适配器 #

在消息流配置中，为JMS出站适配器指定事务同步工厂，同时确保整个流程处于事务上下文（比如通过@Transactional注解或TransactionInterceptor开启事务）：

.handle(Jms.outboundAdapter(connectionFactory)
        .destination("outputqueue")
        .configureJmsTemplate(jmsTemplateSpec -> jmsTemplateSpec.id("jmsTemplateOutbound")
            .sessionTransacted(true)
        ),
    e -> e.transactional(dbUpdateSyncFactory()))

业务流程匹配说明 #

你的需求（消息入队开启事务，发送出站消息后提交JMS操作并同步更新数据库）可通过上述方案实现：事务覆盖JMS发送与数据库更新操作，只有当JMS发送成功并提交事务后，才会触发afterCommit中的数据库更新，保证操作的原子性。

内容的提问来源于stack exchange，提问作者VPN236