Spring JMS监听器阻塞问题：Apple与Pear应用消息处理异常排查

这种情况我之前处理过类似的场景，核心问题出在事务传播机制和JMS消息的事务可见性上，结合你的配置和业务流程拆解如下：

核心原因：事务未提交导致消息不可见 #

你的AppleMessageListener的整个执行流程（消费消息→修改重发→等待响应）是在Spring JMS listener容器管理的同一个事务中进行的，具体逻辑链如下：

1. 从配置能看到，两个DefaultMessageListenerContainer都绑定了transactionManager，这意味着容器会为每个消费请求开启一个事务，消费、生产消息的操作都被包裹在这个事务范围内。
2. 当AppleMessageListener把修改后的消息（ID=PEAR_ID）写入outQueue时，这条消息处于事务未提交状态——WildFly的JMS Broker不会将未提交的事务内消息投递给任何消费者，包括PearMessageListener。
3. 由于AppleMessageListener一直在等待inQueue的响应，这个事务始终无法完成提交，直到超时后容器强制结束事务，这条PEAR_ID的消息才会被Broker正式发布到队列中，此时PearMessageListener才能读取到它。

针对性解决方案 #

1. 剥离消息发送操作到独立事务 #

把发送PEAR_ID消息的逻辑单独放到一个新事务中执行，确保消息能立即提交到队列，让Pear的监听器及时看到：
在AppleMessageListener中，给发送消息的方法添加@Transactional(propagation = Propagation.REQUIRES_NEW)注解，让发送操作在独立事务中完成并提交：

@Service
public class AppleMessageListener implements MessageListener {
    @Autowired
    private JmsTemplate jmsTemplate;

    @Override
    @Transactional // 消费原消息的事务
    public void onMessage(Message message) {
        // 1. 处理原消息的业务逻辑
        // ...

        // 2. 发送PEAR_ID消息到outQueue，使用独立事务提交
        sendPearTargetMessage(message);

        // 3. 等待inQueue的响应（此时发送操作已提交，Pear能立即收到消息）
        waitForPearResponse();
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private void sendPearTargetMessage(Message originalMessage) {
        // 修改消息ID为PEAR_ID并发送
        jmsTemplate.convertAndSend("outQueue", modifiedContent, msg -> {
            msg.setStringProperty("ID", "PEAR_ID");
            return msg;
        });
    }
}

2. 将等待响应逻辑移出消费事务 #

如果业务允许，可以先完成消费和消息发送的事务提交，再去监听inQueue的响应，避免事务长时间挂起：

@Override
@Transactional
public void onMessage(Message message) {
    // 1. 处理原消息业务
    // ...

    // 2. 发送PEAR_ID消息（事务内完成，提交后消息立即可见）
    sendPearTargetMessage(message);
    
    // 3. 记录关联ID，触发异步等待逻辑
    String correlationId = message.getJMSCorrelationID();
    asyncWaitForResponse(correlationId);
}

// 异步等待响应，不阻塞消费事务
@Async
public void asyncWaitForResponse(String correlationId) {
    // 监听inQueue的响应逻辑
    // ...
}

3. 调整Listener容器的事务配置（可选） #

如果业务不需要消费消息的事务性，可以修改DefaultMessageListenerContainer的配置，移除transactionManager属性，让消费操作在非事务模式下执行，这样发送的消息会立即生效：

<bean id="appleMessageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="destination" ref="outQueue" />
    <property name="destinationResolver" ref="jmsDestinationResolver" />
    <property name="messageListener" ref="AppleMessageListener" />
    <property name="messageSelector" value="ID='APPLE_ID'" />
    <!-- 移除transactionManager配置，改为非事务模式 -->
</bean>

注意：这种方式会失去消费消息的事务回滚能力，如果Apple处理消息失败，已经消费的消息无法回滚到队列，需要根据业务场景评估风险。

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