如何为指定ActiveMQ队列配置消息过期策略

• 直接调用message.setJMSExpiration(XYZ)无效是JMS规范明确要求：JMSExpiration属于Broker侧维护的保留字段，客户端直接设置的值会被ActiveMQ Broker和Spring JMS框架直接覆盖，正确的TTL设置方式是通过消息生产者的TTL参数传入，而非直接修改消息对象的该属性。
• 你之前的deadLetterStrategy配置存在两处错误：
  • processExpired="false"的语义是直接丢弃所有过期消息，不会将其投递到DLQ，和需求完全相反
  • expiration="0"在该配置下的语义是「不修改投递到DLQ的消息原有过期时间」，而非设置为永不过期，要实现DLQ/RTS消息永不过期需要明确指定覆盖值，同时要保证deadLetterStrategy嵌套在<destinationPolicy><policyMap><policyEntries><policyEntry>节点下，否则配置不会被加载。

该方案实现成本最低，无需改动大量应用代码，配置步骤如下：

1. 在ActiveMQ主配置文件的<broker>节点下添加如下队列策略配置，给incoming、outgoing队列设置默认TTL，DLQ、RTS队列消息永久保留：

<destinationPolicy>
  <policyMap>
    <policyEntries>
      <!-- incoming队列设置固定TTL，按需求替换12345为实际需要的毫秒值 -->
      <policyEntry queue="incoming.>" timeToLive="12345">
        <deadLetterStrategy>
          <individualDeadLetterStrategy
            processNonPersistent="true"
            queuePrefix="DLQ."
            useQueueForQueueMessages="true"
            processExpired="true"
            expirationOverride="0"
            enableAudit="false"/>
        </deadLetterStrategy>
      </policyEntry>
      <!-- outgoing队列设置固定TTL -->
      <policyEntry queue="outgoing.>" timeToLive="12345">
        <deadLetterStrategy>
          <individualDeadLetterStrategy
            processNonPersistent="true"
            queuePrefix="DLQ."
            useQueueForQueueMessages="true"
            processExpired="true"
            expirationOverride="0"
            enableAudit="false"/>
        </deadLetterStrategy>
      </policyEntry>
      <!-- DLQ、RTS队列TTL设为0，消息永久保留 -->
      <policyEntry queue="DLQ.>" timeToLive="0"/>
      <policyEntry queue="RTS.>" timeToLive="0"/>
    </policyEntries>
  </policyMap>
</destinationPolicy>

2. 添加虚拟目的地拦截器，保证转发到RTS队列的消息TTL被重置为0：

<plugins>
  <destinationInterceptors>
    <virtualDestinationInterceptor>
      <virtualDestinations>
        <compositeQueue name="*" forwardOnly="false">
          <forwardTo>
            <!-- 按实际RTS路由规则修改匹配条件，转发到RTS时强制TTL为0 -->
            <filteredDestination selector="需要转发到RTS的消息匹配条件" queue="RTS.${destination.name}" timeToLive="0"/>
          </forwardTo>
        </compositeQueue>
      </virtualDestinations>
    </destinationInterceptors>
  </destinationInterceptors>
</plugins>

3. 应用侧如果需要自定义outgoing队列的TTL，在Spring JMS配置中开启QoS支持即可，无需直接修改JMSExpiration属性：

// 为JmsTemplate开启显式QoS配置
jmsTemplate.setExplicitQosEnabled(true);

// 发送消息时可单独指定TTL，该值优先级高于Broker侧配置的默认TTL
long customTtl = 60000; // 自定义过期时间，单位毫秒
jmsTemplate.convertAndSend("outgoing.你的队列名", "消息内容", customTtl);

如果需要incoming队列消息永久保留，仅outgoing队列消息带过期时间，只需修改上述方案二的策略配置即可：

• 将incoming.>对应policyEntry的timeToLive属性改为0，incoming队列消息默认永不过期
• 保留outgoing队列的TTL配置，同时支持应用侧通过JmsTemplate传入自定义TTL值
• DLQ、RTS队列的配置和方案二完全一致，所有进入这两个队列的消息都会被重置TTL为0永久保留。

• 配置修改完成后重启ActiveMQ Broker，发送测试消息后通过ActiveMQ管理控制台查看消息的JMSExpiration字段，确认不同队列的TTL符合预期
• 禁止在业务代码中直接调用message.setJMSExpiration()，该方法设置的值永远不会被Broker采纳，所有TTL设置要么通过Broker的destination policy配置，要么通过生产者的timeToLive参数传入。

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