如何在JMS监听器中指定队列消息监听选项（替代IBM MQ）

可以通过JMS（尤其是IBM官方的JMS客户端）实现你当前IBM MQ原生代码的功能，同时支持灵活的消息过滤规则。以下是具体实现方案：

一、对应原生GMO选项的JMS实现 #

你原代码中的两个GMO选项，在JMS中可以通过以下方式实现：

1. 对应MQC.MQGMO_NO_WAIT（无消息时立即返回） #

如果是同步获取消息，直接调用MessageConsumer.receive(0)即可——超时时间设为0时，无消息会立即抛出JMSException（部分客户端会返回null，需根据实际客户端调整），和原生NO_WAIT的行为一致。

如果是异步监听器（MessageListener），监听器本身是持续等待消息的模式，若要模拟无等待的非阻塞逻辑，可结合同步获取的方式实现，或者通过配置客户端的超时参数调整。

2. 对应MQC.MQGMO_FAIL_IF_QUIESCING（队列管理器静默时操作失败） #

IBM的JMS客户端（com.ibm.mq.jms）提供了扩展配置，在创建MQConnectionFactory时设置setFailIfQuiescing(true)即可：

MQConnectionFactory factory = new MQConnectionFactory();
// 其他连接配置（地址、端口、队列管理器、通道等）...
factory.setFailIfQuiescing(true);

这样当队列管理器进入静默/停止状态时，消息操作会直接抛出异常，和原生API的行为匹配。

二、JMS的消息过滤规则实现 #

JMS支持两种主流的消息过滤方式，满足不同场景需求：

1. 标准JMS消息选择器 #

基于SQL92语法的表达式，过滤消息的自定义属性或标准JMS头字段。创建消费者时指定选择器即可：

// 过滤优先级大于3、消息类型为ORDER的消息
String selector = "JMSPriority > 3 AND JMSType = 'ORDER'";
MessageConsumer consumer = session.createConsumer(queue, selector);

2. IBM MQ原生字段过滤 #

如果需要基于MQMD（MQ消息描述符）的原生字段过滤，IBM JMS客户端允许通过JMS_IBM_MQMD_*前缀引用这些字段，比如：

// 过滤消息类型为应答（MQMT_REPLY=8）的消息
String selector = "JMS_IBM_MQMD_MsgType = 8";
MessageConsumer consumer = session.createConsumer(queue, selector);

完整示例代码 #

import com.ibm.mq.jms.MQConnectionFactory;
import javax.jms.*;

public class JMSMQExample {
    public static void main(String[] args) throws JMSException {
        // 初始化连接工厂
        MQConnectionFactory factory = new MQConnectionFactory();
        factory.setHostName("your-mq-host");
        factory.setPort(1414);
        factory.setQueueManager("QMGR_NAME");
        factory.setChannel("CHANNEL_NAME");
        // 开启FAIL_IF_QUIESCING对应功能
        factory.setFailIfQuiescing(true);

        // 创建JMS上下文（简化版的连接+会话）
        try (JMSContext context = factory.createContext()) {
            Queue queue = context.createQueue("queue:///TARGET_QUEUE");

            // 带过滤规则创建消费者
            String selector = "JMS_IBM_MQMD_Priority > 3";
            MessageConsumer consumer = context.createConsumer(queue, selector);

            // 同步获取消息（对应NO_WAIT）
            try {
                Message message = consumer.receive(0);
                if (message != null) {
                    System.out.println("Received message: " + ((TextMessage) message).getText());
                }
            } catch (JMSException e) {
                System.out.println("No message available (matches NO_WAIT behavior)");
            }

            // 异步监听器示例（带过滤）
            consumer.setMessageListener(message -> {
                try {
                    System.out.println("Async received message: " + ((TextMessage) message).getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            });

            // 保持程序运行以接收异步消息
            try {
                Thread.sleep(30000);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
}

内容的提问来源于stack exchange，提问作者Chaitnya Joshi