JMS事务问题：发送事务未提交导致无法接收消息的解决方案咨询

针对你遇到的问题——AppleListener在同一个事务内发送消息到outQueue后，PearListener无法立即接收，同时AppleListener等待响应超时，核心原因正如IBM文档所说：事务内发送的消息要等到事务提交才会被投递，而你的AppleListener整个逻辑都在事务包裹中，导致消息一直处于未提交状态，PearListener自然拿不到，同时AppleListener在事务内等待响应也会卡住。

下面给你几个可行的解决方案，你可以根据业务场景选择：

方案一：拆分事务，将消息发送操作放入独立事务 #

把AppleListener中发送消息给Pear的逻辑单独封装到一个新事务中，这样发送操作的事务会独立提交，消息会立即投递到队列，PearListener就能及时处理。

比如在你的AppleMessageListener中，把发送消息的逻辑抽出来，用@Transactional(Propagation.REQUIRES_NEW)注解标记：

@Component
public class AppleMessageListener implements MessageListener {

    @Autowired
    private AppleMessageProcessor messageProcessor;
    @Autowired
    private CrossAppMessageSender crossAppMessageSender;
    @Autowired
    private PearResponseHandler responseHandler;

    @Override
    @Transactional
    public void onMessage(Message message) {
        // 1. 处理Apple业务逻辑（当前事务内）
        Message updatedMessage = messageProcessor.processAppleMessage(message);
        
        // 2. 发送消息给Pear，触发新事务
        crossAppMessageSender.sendToOutQueueWithPearId(updatedMessage);
        
        // 3. 等待Pear的响应或超时（此时消息已提交，Pear可处理）
        responseHandler.waitForResponseOrTimeout(updatedMessage.getJMSCorrelationID());
    }
}

// 单独的消息发送组件
@Component
public class CrossAppMessageSender {

    @Autowired
    private JmsTemplate jmsTemplate;
    @Autowired
    private Destination outQueue;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void sendToOutQueueWithPearId(Message message) throws JMSException {
        // 设置消息Selector为PEAR_ID
        message.setStringProperty("ID", "PEAR_ID");
        // 发送消息
        jmsTemplate.send(outQueue, session -> {
            TextMessage textMessage = session.createTextMessage(message.getBody(String.class));
            textMessage.setJMSCorrelationID(message.getJMSCorrelationID());
            return textMessage;
        });
    }
}

这里的关键是REQUIRES_NEW传播行为：它会暂停当前事务，开启一个新事务，发送消息后立即提交新事务，这样消息就会被立即投递，不需要等AppleListener的主事务完成。

方案二：使用非事务性消息发送（业务允许的情况下） #

如果Apple的业务更新和发送消息不需要强一致性（比如即使后续更新失败，已经发送给Pear的消息不需要回滚），可以配置一个非事务性的JmsTemplate来发送消息：

<!-- 非事务性JmsTemplate，用于发送不需要和主事务绑定的消息 -->
<bean id="nonTransactionalJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
    <!-- 关闭事务，发送后立即投递 -->
    <property name="sessionTransacted" value="false"/>
</bean>

然后在AppleListener中使用这个模板发送消息，这样消息会绕过当前事务，直接投递到队列，PearListener能马上处理。但要注意这种方式的风险：如果AppleListener的主事务后续回滚，已经发送的消息无法撤回，需要确认业务可以接受这种“最终一致性”的场景。

方案三：调整消息流转路径，避免复用同一个队列 #

从架构设计角度，建议把Apple的输出和Pear的输入分开，比如新增一个pearInputQueue：

• AppleListener处理完消息后，发送到pearInputQueue（而不是写回outQueue）
• PearListener监听pearInputQueue，处理后发送响应到inQueue

这种方式不仅解决了事务问题，还让消息流向更清晰，避免了同一个队列的Selector过滤可能带来的混乱，也便于后续排查问题。

额外注意事项 #

• 等待响应的逻辑：不要在Listener线程中长时间阻塞，建议用JmsTemplate.receiveSelected()设置合理的超时时间，或者用异步接收（比如Spring的@JmsListener结合异步处理），避免占用Listener线程导致队列堆积。
• WildFly事务配置：确保你的Spring事务管理器和WildFly的JMS连接工厂兼容，如果用的是XA事务，要配置XA事务管理器，避免事务不一致。
• 消息Selector验证：确认ID='APPLE_ID'和ID='PEAR_ID'的Selector能精准匹配消息，避免消息被错误的Listener接收。

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