20.6.11. 设置消息过期

介绍

如果发送的消息没有在指定时间（毫秒）内递送给消费者，它们可被设置为过期。使用 Java 消息服务（JMS）或 HornetQ Core API，您可以直接在消息上设置过期时间。例如： 

// message will expire in 5000ms from now
message.setExpiration(System.currentTimeMillis() + 5000);
JMS MessageProducer 包含了一个 TimeToLive 参数，它控制发送的消息的过期： 
// messages sent by this producer will be retained for 5s (5000ms) before expiration           
producer.setTimeToLive(5000);
从过期地址消费的过期消息具有下列属性：
  • _HQ_ORIG_ADDRESS
包含过期消息的原始地址的字符串型属性
  • _HQ_ACTUAL_EXPIRY
包含过期消息的实际过期时间的长整型属性。
配置消息过期地址

消息过期地址是在 JMS 的 address-setting 配置里定义的： 

<!-- expired messages in exampleQueue will be sent to the expiry address expiryQueue -->
<address-setting match="jms.queue.exampleQueue">
   <expiry-address>jms.queue.expiryQueue</expiry-address>
</address-setting>
如果消息已过期且没有指定过期地址，消息将从队列里删除并丢弃。
配置 Expiry Reaper 线程

Reaper 线程会定期地检查队列以检验消息是否过期。

  • message-expiry-scan-period
扫描队列以检测过期消息的频率（毫秒为单位，默认是 30000毫秒。-1 表示禁用 Reaper 线程）。
  • message-expiry-thread-priority
Reaper 线程的优先级。它必须是 0 - 9 之间的值，9 表示最高优先级。默认值为 3。
提交 bug 报告