如何在Amazon MQ中为特定队列设置消息过期策略？

由于Amazon MQ基于ActiveMQ Classic，且不支持Artemis风格的<address-setting>配置，你可以通过以下两种方式实现特定队列的消息过期控制：

1. 生产者端指定消息过期时间 #

在发送消息到目标队列时，直接通过JMS API为每条消息设置过期时间（JMSExpiration），仅对发送到该队列的消息生效。示例Java代码：

// 创建消息
TextMessage message = session.createTextMessage("测试消息");
// 设置10秒后过期（单位：毫秒）
message.setJMSExpiration(System.currentTimeMillis() + 10000);
// 发送到exampleQueue
producer.send(queue, message);

这种方式无需修改Broker配置，灵活性强，完全针对目标队列的消息生效。

2. 通过Broker的Destination Policy配置特定队列规则 #

Amazon MQ支持在Broker的XML配置中添加<destinationPolicy>，针对特定队列设置默认消息过期时间，所有发送到该队列且未单独设置过期的消息都会应用此规则。配置示例：

<broker xmlns="http://activemq.apache.org/schema/core">
  <!-- 保留原有其他配置 -->
  <destinationPolicy>
    <policyMap>
      <policyEntries>
        <!-- 匹配目标队列exampleQueue -->
        <policyEntry queue="exampleQueue">
          <timeToLiveStrategy>
            <!-- 设置默认过期时间为10秒（单位：毫秒） -->
            <defaultTimeToLiveStrategy expiry="10000"/>
          </timeToLiveStrategy>
        </policyEntry>
      </policyEntries>
    </policyMap>
  </destinationPolicy>
  <!-- 保留原有其他配置 -->
</broker>

你可以在Amazon MQ控制台创建或修改Broker时，将上述配置添加到ActiveMQ XML配置区域，Broker重启后即可生效。

注意：如果同时使用两种方式，生产者端设置的消息过期时间优先级高于Broker配置的默认值。

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