Spring Integration JMS消息驱动通道适配器：Qpid队列消息未删除问题

我太懂这种头疼的情况了——消息读了却清不掉，新消息还捡不到，大概率是JMS确认机制或者事务配置出了问题，结合你的场景咱们一步步捋：

核心问题根源 #

你遇到的“消息处于已获取状态未删除”“新消息无法被拾取”，本质是消息的确认信号没正常发给Qpid，或者适配器的消费线程被未完成的事务卡住了。

具体排查&解决方案 #

1. 先检查确认模式配置 #

Spring Integration的jms:message-driven-channel-adapter默认的确认逻辑很容易踩坑：如果没明确配置，它可能会用CLIENT_ACKNOWLEDGE模式，这时候需要你的代码手动调用确认方法，但Spring Integration默认不会帮你做这个！

所以第一步必须给适配器加上acknowledge="auto"，让消息被成功处理后自动给Qpid发确认，队列就会删除消息了。示例配置：

<jms:message-driven-channel-adapter 
    destination-name="incoming.queue" 
    channel="transform-jms-message-channel"
    acknowledge="auto"
    connection-factory="qpidConnectionFactory"/>

2. 排查事务是否正常提交 #

如果你给适配器配置了事务管理器（比如transaction-manager属性），那一定要确保整个处理流程没有未捕获的异常——只要有异常抛出，事务就会回滚，消息会被Qpid标记为“已获取”但不会删除，直到超时后才会重新回到队列。同时，卡住的事务会占住消费线程，导致新消息没人处理。

解决办法：

• 给适配器加上error-channel，把异常单独捞出来处理，避免事务一直卡着：

<jms:message-driven-channel-adapter 
    destination-name="incoming.queue" 
    channel="transform-jms-message-channel"
    error-channel="jms-error-channel"
    acknowledge="auto"/>

• 检查事务管理器的配置，确保它关联的是Qpid的连接工厂：

<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
    <property name="connectionFactory" ref="qpidConnectionFactory"/>
</bean>

3. 调整Qpid的预取设置 #

Qpid有个**预取（prefetch）**机制，会提前把一批消息发给消费者。如果这些预取的消息都处于未确认状态，队列就不会再发新消息给适配器了。你可以调整预取值，避免一次性拿太多消息：

<bean id="qpidConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory">
    <property name="remoteURI" value="amqp://localhost:5672"/>
    <property name="username" value="admin"/>
    <property name="password" value="admin"/>
    <property name="prefetchPolicy">
        <bean class="org.apache.qpid.jms.policy.JmsDefaultPrefetchPolicy">
            <property name="queuePrefetch" value="10"/> <!-- 按你的处理能力调整，别太大 -->
        </bean>
    </property>
</bean>

4. 优化适配器并发数 #

如果适配器的concurrent-consumers设置得太小，而未确认的消息占满了所有线程，新消息自然没人去捡。可以适当调高并发数：

<jms:message-driven-channel-adapter 
    destination-name="incoming.queue" 
    channel="transform-jms-message-channel"
    acknowledge="auto"
    concurrent-consumers="3"/>

快速验证步骤 #

1. 先临时去掉事务配置，只保留acknowledge="auto"，发一条测试消息，看处理完后队列里的消息是不是被删掉了。
2. 在你的消息处理逻辑里加详细日志，确认消息是不是真的走完了整个流程，有没有半路抛异常。
3. 打开Qpid的管理控制台（如果有的话），看看那些“已获取”的消息会不会在超时后重新变为可用状态——这能帮你确认是确认问题还是事务问题。

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