过滤器与消息选择器

过滤器

String filter = "(currentRate - newRate) >= 1.0";
TopicSubscriber subscriber =
session.createSubscriber(topic, filter, true);

如上，设置了过滤器。比较简单，核心的地方是选择器上。支持加过滤器是在通过session创建TopicSubscriber.，QueueReceiver，QueueBrowser的时候设置。

选择器
不支持对消息内容的过滤。只支持对属性和头的选择条件。，选择器的代码结构与SQL-92的语法基本类似。

标示符
Symbol = 'ABC' AND Side = 'BUY' AND Shares <= 1000.0 AND JMSPriority > 4

msg.setStringProperty("Symbol", tradeOrder.getSymbol());
msg.setStringProperty("Side", tradeOrder.getSide());
msg.setDoubleProperty("Shares", tradeOrder.getShares());

如上，需要注意的是，头名或者属性名是区分大小写的。

常用的头名有
• JMSDeliveryMode
• JMSPriority
• JMSMessageID
• JMSTimestamp
• JMSCorrelationID
• JMSType

JMSDestination and JMSReplyTo 这两个头是不能作为条件的，因为他们对应的值是目标，其值是无法确定的。
JMSRedelivered 也是不允许的，因为他可能会被改变。
JMSExpiration也不允许，因为不同的JMS实现，对该值的设置也有区别。


比较操作符
多个逻辑运算通过AND 和 OR进行组合。
支持
• 6个代数比较符号( = , > , >= , < ,<= , and <>)
• LIKE
• BETWEEN
• IN
• NOT
• IS NULL

运算符
如+ - * /


对于发布订阅模式，public MessageConsumer createConsumer(Destination dest,
String messageSelector,
boolean noLocal)，多了一个参数，该参数是只是否包含了自己发布的消息。

另外在选择器和使用多个队列或者主题，已达到选择器的功能上，更亲睐于使用多个队列，而不是使用选择器，因为选择器会增加依赖关系（应用A需要知道应用B的消息的部分属性或者头的内容）。
更好的方式是先做一个分析，推算出需要的主题或者队列数，做一个合理划分，在做小量的选择器，以求达到解耦和JMS中间件压力的均衡。