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

2023-12-31

我正在尝试编写一个简单的测试用例,以根据消息属性从队列中提取消息,命中 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(使用前将#替换为@)

如何使用 Java API 设置消息选择器? 的相关文章

随机推荐

  • 如何从多项式拟合中提取方程?

    我的目标是将一些数据拟合到多项式函数并获得包括拟合参数值的实际方程 我适应了这个例子 http scikit learn org stable auto examples linear model plot polynomial inter
  • Apple 开发人员 - 无效的 CSR、无效证书

    我生成 certSigningRequest通过钥匙串访问文件 Keychain Access gt Certificate Assistant gt Request a Certificate From a Certificate Aut
  • AS3 中强制垃圾收集?

    是否可以以编程方式强制在 ActionScript 3 0 中运行完整的垃圾回收 假设我已经使用 eventListener 创建了一堆 Display 对象 并且一些 DO 已被删除 一些 eventListener 已被触发并删除等 是
  • 根据另一个值过滤元素

    我想输出 ReactJs 中每个帖子的所有问题的数量 为此 我创建了下一个代码 const posts title 1 id 123 title 2 id 1234 title 3 id 12345 const questions id 5
  • Excel (2007) VBA - .Formula 包含引号

    我昨天尝试将以下代码放入程序中 VBA 调用了一个错误 我认为这是因为公式内的双引号 我用谷歌搜索 发现的所有结果都只是给出了输入公式的基本知识 但没有一个解释如何绕过里面的引号 之前有一个With语句 Pivot是工作表名称 Range
  • 在 awk 中使用 if 块

    我正在 awk 中处理一个文件 我想要传递文件中第 25 到 34 列位置有空格的行 并且想要处理第 10 到 19 列位置有空格的行 具体来说 我想用 0 替换列位置 10 到 19 中的空格 这样 输出文件的 25 34 行中的空白行将
  • 构建docker实例时如何安装本地rpm文件?

    我有以下 docker 文件 我想在构建 docker 实例时专门安装磁盘上可用的 rpm 文件 我对 rpm install 的调用如下所示 命令RUN rpm i chrpath 0 13 14 el7 x86 64 rpm fails
  • Logback 不使用配置文件

    我正在尝试将进程的日志保存到文件中 当我在 netbeans 中运行该类时 这工作正常 但在导出 JAR 文件后 该进程无法选择 logback xml jar 文件与 logback xml 位于同一路径中 我尝试使用我在这里找到的所有示
  • 文本视图返回错误的文本大小

    我需要获取文本视图的文本大小 以便在用户按下按钮时增加文本大小 这表明它有助于增加文本视图中的文本大小 让我清楚到目前为止我做了什么 我有一个文本视图并通过 dimen 文件夹设置其文本大小
  • 解析失败:Lcom/google/android/aidl/BaseStub;

    我更新了 implementation com android installreferrer installreferrer X from 1 1 2 to 2 0 然后开始收到此错误 Process com tomatedigital
  • 在struts 2中为字符串列表制作一个垂直的单选按钮列表?

    我正在使用一个 struts radio 标签 该标签填充了一个字符串列表 我正在使用的视图是 tr td td tr
  • 实体数据查询和内存泄漏

    我正在循环下载大量数据 但经过一些操作后 我删除了它们 但我看到内存分配增长得非常快 几秒钟就达到了 1GB 那么如何在每次迭代后进行清理呢 using var contex new DB var inputs contex AIMRInp
  • 客户端 Web 应用程序中的 GPG (PGP) 解密

    如何在 Web 应用程序的客户端解密某些加密数据 E g 数据以加密方式存储在服务器上 它使用公共 GPG 密钥进行加密 服务器将加密后的数据发送给客户端 客户端需要使用本地私钥对其进行解密 假设我能够将私钥传递给浏览器并使用 JavaSc
  • Mongo嵌入文档查询

    我有 2 个动态文档 class Tasks db DynamicDocument task id db UUIDField primary key True default uuid uuid4 name db StringField f
  • 带有闰秒的持续时间

    我需要在固定的日期时间在代码中安排任务 为此 我使用 ScheduledExecutorService 和方法schedule Runnable command long delay TimeUnit unit 如何根据闰秒计算此延迟 目前
  • 如何在asp.net中获取当前的windows用户?

    我尝试了很多代码 它在我的本地服务器上成功运行 但我尝试将远程服务器放在远程服务器上 他们得到另一个字符串 例如 IIS APPPOOL 服务器名称 我更改了 IIS 管理器中的某些设置 但失败了 我如何获取远程服务器中的用户名 我尝试了一
  • Silverlight转WCF跨域异常,但clientaccesspolicy.xml读取成功

    clientaccesspolicy xml
  • 常规静态类

    这个文件sample groovy 中的 static 有什么作用 static class froob 不管有没有 static groovy 代码都可以很好地编译 绝对没有区别 这种情况下的静电被忽略 为了进行测试 我创建了一个 gro
  • Pandas read_excel 返回 PendingDeprecationWarning

    我一直在使用以下命令将 Excel 文件导入为 Pandas 数据框read excel到目前为止 功能尚未出现明显问题 然而 我刚刚意识到 在最近的一些更新之后 我收到以下警告 usr local lib python3 7 site p
  • 如何使用 Java API 设置消息选择器?

    我正在尝试编写一个简单的测试用例 以根据消息属性从队列中提取消息 命中 7 5 0 3 QMgr 并使用 7 5 0 3 客户端 jar 我在网上看到的所有内容都表明我需要在打开队列时指定消息选择器 我对此很满意 但我只看到两种打开它的方法