如何在Spring Boot的Camel消费者中为IBM MQ连接工厂设置MQOO_INPUT_EXCLUSIVE选项

要实现单实例独占消费IBM MQ队列以保证消息顺序，你需要明确：MQOO_INPUT_EXCLUSIVE是IBM MQ的队列打开选项，而非连接级属性，因此不能直接在MQQueueConnectionFactory上配置，需要在Camel的JMS消费端点中指定IBM MQ专属参数。

具体实现方式 #

方式1：在Camel路由的JMS URI中直接指定 #

在定义Camel路由时，给JMS端点添加ibmMQOptions参数，传入MQOO_INPUT_EXCLUSIVE对应的数值（0x80）：

@Override
public void configure() throws Exception {
    from("jms:queue:YOUR_QUEUE_NAME?ibmMQOptions=0x80")
        .process(exchange -> {
            // 处理消息逻辑
        });
}

如果想使用常量提高可读性，可以引入IBM MQ的MQConstants类，直接用MQConstants.MQOO_INPUT_EXCLUSIVE：

import com.ibm.mq.MQConstants;

@Override
public void configure() throws Exception {
    from(String.format("jms:queue:YOUR_QUEUE_NAME?ibmMQOptions=%d", MQConstants.MQOO_INPUT_EXCLUSIVE))
        .process(exchange -> {
            // 处理消息逻辑
        });
}

方式2：通过JmsConfiguration全局配置 #

如果需要给多个端点统一配置，可以通过JmsConfiguration设置ibmMQOptions，再关联到JmsComponent：

@Configuration
public class CamelMqConfig {

    @Bean
    public MQQueueConnectionFactory mqQueueConnectionFactory() {
        MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
        // 配置你的MQ连接参数：主机、端口、队列管理器、通道等
        factory.setHostName("MQ_HOST");
        factory.setPort(1414);
        factory.setQueueManager("QMGR_NAME");
        factory.setChannel("CHANNEL_NAME");
        factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
        return factory;
    }

    @Bean
    public JmsConfiguration jmsConfiguration(MQQueueConnectionFactory connectionFactory) {
        JmsConfiguration config = new JmsConfiguration();
        config.setConnectionFactory(connectionFactory);
        // 设置独占消费选项
        config.setIbmMQOptions(MQConstants.MQOO_INPUT_EXCLUSIVE);
        return config;
    }

    @Bean
    public JmsComponent jmsComponent(JmsConfiguration jmsConfiguration) {
        JmsComponent component = JmsComponent.jmsComponentAutoAcknowledge(jmsConfiguration);
        return component;
    }
}

这样配置后，所有使用该JmsComponent的Camel JMS端点都会自动带上独占打开队列的选项。

关键说明 #

• MQOO_INPUT_EXCLUSIVE的作用是：当一个消费者以独占模式打开队列后，其他消费者尝试打开同一队列时会收到MQRC_OBJECT_IN_USE错误，从而保证只有一个实例能消费队列消息，维持顺序。
• 不要混淆连接属性和队列打开属性：MQQueueConnectionFactory负责创建与MQ的连接，而队列打开选项是在消费/访问队列时指定的参数，必须绑定到端点或全局JMS配置中。

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