如何使用接收器中的选择器过滤 JMS 消息 class
How to filter JMS message using selector in receiver class
我想使用队列中存在超过 3 分钟的消息。
下面是我的class消费。如何在选择器中定义条件。
@Async
@JmsListener(destination = "jms/xyz" ,containerFactory = "xyzfactory", selector = "JMSTimestamp= 'morethan 3 minuts'")
public void xyzRecive(Message message) throws JMSException {
}
选择器需要类似于：
"JMSTimestamp > " + (System.currentTimeMillis() + 180000);
但是，选择器是在创建时在底层 JMS 使用者上设置的，并且是不可变的，因此该选择器会快速增长 "stale"，因为时间总是在向前发展。要更改选择器，需要关闭现有消费者并使用新选择器创建新消费者。显然，在这种情况下 Spring 正在处理消费者的创建并设置选择器，因此您要么需要删除 Spring 并自己使用 JMS API（这并不难） .
另一个可能的解决方案是将消息的生存时间设置为 3 分钟，并在您使用的任何代理上定义一个过期队列，并从该过期队列而不是主队列中消费，因为所有过期队列中的消息将保证在主队列中至少停留 3 分钟。
我想使用队列中存在超过 3 分钟的消息。
下面是我的class消费。如何在选择器中定义条件。
@Async
@JmsListener(destination = "jms/xyz" ,containerFactory = "xyzfactory", selector = "JMSTimestamp= 'morethan 3 minuts'")
public void xyzRecive(Message message) throws JMSException {
}
选择器需要类似于：
"JMSTimestamp > " + (System.currentTimeMillis() + 180000);
但是，选择器是在创建时在底层 JMS 使用者上设置的，并且是不可变的，因此该选择器会快速增长 "stale"，因为时间总是在向前发展。要更改选择器，需要关闭现有消费者并使用新选择器创建新消费者。显然，在这种情况下 Spring 正在处理消费者的创建并设置选择器，因此您要么需要删除 Spring 并自己使用 JMS API（这并不难） .
另一个可能的解决方案是将消息的生存时间设置为 3 分钟，并在您使用的任何代理上定义一个过期队列，并从该过期队列而不是主队列中消费，因为所有过期队列中的消息将保证在主队列中至少停留 3 分钟。