我正在尝试编写一个简单的测试用例,以根据消息属性从队列中提取消息,命中 7.5.0.3 QMgr 并使用 7.5.0.3 客户端 jar。
我在网上看到的所有内容都表明我需要在打开队列时指定消息选择器。我对此很满意,但我只看到两种打开它的方法:
MQQueueManager.accessQueue(
String queueName,
int openOptions);
MQQueueManager.accessQueue(
String queueName,
int openOptions,
String queueMgr,
String dynamicQueueName,
String altUserId);
这些都不允许我指定消息选择器。我从命令行批处理应用程序运行此程序,而不是在应用程序服务器中运行,因此无法使用 JMS 选择器。
以下是有关选择器的 IBM 文档:WebSphere MQ 消息选择器 http://www-01.ibm.com/support/knowledgecenter/SSFKSJ_7.5.0/com.ibm.mq.dev.doc/q022990_.htm这表明选择必须作为 MQOPEN 调用的一部分进行。
MQ JMS API 提供您正在寻找的消息选择语法类型。基本 MQ Java API 提供基于 MessageId 和 CorrelationId 的消息选择,但尚未提供您正在寻找的类型选择语法。您提供的文档链接适用于 MQ C API。
使用 MQ JMS API,可以进行消息选择,如下所示:
// Create JMS objects
connection = cf.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Create queue destination
Destination queDest= session.createQueue(que);
// Create consumer with selector
String selector = "category='bucket1'";
MessageConsumer cons= session.createConsumer(queDest, selector);
connection.start();
// receive messages
Message inMessage = cons.receive(5000);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)