java - 如何使用接收器类中的选择器过滤JMS消息

Question

我想使用队列中存在时间超过 3 分钟的消息。

下面是我的消费类。如何在选择器中定义条件。

@Async
@JmsListener(destination = "jms/xyz" ,containerFactory = "xyzfactory", selector = "JMSTimestamp= 'morethan 3 minuts'")
public void xyzRecive(Message message) throws JMSException {

}

Answer 1

选择器需要类似于:

"JMSTimestamp > " + (System.currentTimeMillis() + 180000);

但是，选择器是在创建时在底层 JMS 使用者上设置的，并且是不可变的，因此该选择器会很快变得“过时”，因为时间总是在前进。要更改选择器需要关闭现有消费者并使用新选择器创建新消费者。显然，在这种情况下，Spring 正在处理使用者的创建并设置选择器，因此您需要放弃 Spring 并自己使用 JMS API(这并不难)。

另一种潜在的解决方案是将消息的生存时间设置为 3 分钟，并在您使用的任何代理上定义一个到期队列，并从该到期队列而不是主队列中进行消耗，因为所有消息过期队列中的数据将保证在主队列中至少存在 3 分钟。