消息过滤

如果没有消息过滤，消费者会收到所有消息，这就需要编写java代码在业务中人工过滤不想要的消息，而使用消息选择器，消费者就只能接收能通过过滤器的那些消息，消息选择器只能使用消息头和消息属性，不能使用消息体内的数据

可用的比较运算符

示例：

String filter = "JMSCorrelationID = '" + msg.getJMSMessageID() + "'";
QueueReceiver qReceiver = qSession.createReceiver(responseQ, filter);

两种消息过滤方式：

 

 

其中多目的地方式生产者需要对消息处理过程了解的更多，以控制消费者接受哪一条消息，使得耦合紧密且扩展较不方便（扩展时不仅需要新增一个队列接收者，还需要新增一个队列以及修改队列发送者）

另外注意在p2p模型中，消息被保证至少传给一个消费者，可以创建一个未传送消息消费者，用来接收那些被其他消息过滤器都排除掉的消息。