首页 > 代码库 > 消息过滤
消息过滤
如果没有消息过滤,消费者会收到所有消息,这就需要编写java代码在业务中人工过滤不想要的消息,而使用消息选择器,消费者就只能接收能通过过滤器的那些消息,消息选择器只能使用消息头和消息属性,不能使用消息体内的数据
可用的比较运算符
示例:
String filter = "JMSCorrelationID = ‘" + msg.getJMSMessageID() + "‘";
QueueReceiver qReceiver = qSession.createReceiver(responseQ, filter);
两种消息过滤方式:
其中多目的地方式生产者需要对消息处理过程了解的更多,以控制消费者接受哪一条消息,使得耦合紧密且扩展较不方便(扩展时不仅需要新增一个队列接收者,还需要新增一个队列以及修改队列发送者)
另外注意在p2p模型中,消息被保证至少传给一个消费者,可以创建一个未传送消息消费者,用来接收那些被其他消息过滤器都排除掉的消息。
消息过滤
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。