如何使用 Java API 设置消息选择器？

Question

我正在尝试编写一个简单的测试用例来根据消息属性从队列中提取消息，达到 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 消息选择器，其中显示选择必须作为 MQOPEN 调用的一部分发生。

Answer 1

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);