码迷,mamicode.com
首页 > 其他好文 > 详细

消息过滤

时间:2017-03-20 16:54:31      阅读:139      评论:0      收藏:0      [点我收藏+]

标签:技术分享   目的   src   http   运算   span   message   ima   ges   

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

技术分享

可用的比较运算符

技术分享

示例:

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

两种消息过滤方式:

技术分享

 

 技术分享

 

 技术分享

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

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

 

消息过滤

标签:技术分享   目的   src   http   运算   span   message   ima   ges   

原文地址:http://www.cnblogs.com/qilong853/p/6589716.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!