监听多个MQ队列时，如何判断触发消息的来源队列？

方案1：通过消息的JMSDestination属性获取来源队列 #

XMS的IMessage对象自带JMSDestination属性，可直接获取消息的目标队列（即来源队列），将其类型转换为IQueue后就能拿到队列名称。

示例代码：

public void OnMessage(IMessage msg)
{
    IDestination dest = msg.JMSDestination;
    if (dest is IQueue sourceQueue)
    {
        string queueName = sourceQueue.QueueName;
        // 根据队列名称执行对应逻辑
        switch (queueName)
        {
            case "QUEUE.A":
                HandleQueueAMessage(msg);
                break;
            case "QUEUE.B":
                HandleQueueBMessage(msg);
                break;
            default:
                HandleUnknownQueueMessage(msg);
                break;
        }
    }
}

方案2：自定义监听器类绑定队列名称 #

创建一个带队列名称参数的自定义监听器，初始化时传入对应队列名，统一的OnMessage方法直接使用该名称识别来源。这种方案不依赖消息属性，逻辑更可控。

自定义监听器代码：

public class UnifiedQueueListener : IMessageListener
{
    private readonly string _sourceQueueName;

    public UnifiedQueueListener(string queueName)
    {
        _sourceQueueName = queueName;
    }

    public void OnMessage(IMessage msg)
    {
        // 直接使用初始化时传入的队列名识别来源
        Console.WriteLine($"处理来自队列 [{_sourceQueueName}] 的消息");
        // 统一处理逻辑，或根据队列名分支
        ProcessMessage(msg, _sourceQueueName);
    }

    private void ProcessMessage(IMessage msg, string queueName)
    {
        // 通用处理逻辑
    }
}

创建消费者时绑定监听器：

// 假设queueList是需要监听的队列名称集合
foreach (var queueName in queueList)
{
    IQueue queue = session.CreateQueue(queueName);
    IMessageConsumer consumer = session.CreateConsumer(queue);
    // 为每个队列的消费者绑定带队列名的监听器
    consumer.MessageListener = new UnifiedQueueListener(queueName);
}

注意事项 #

• 方案1需要确保MQ配置允许访问队列属性，部分场景下可能需要调整权限或连接工厂配置；
• 方案2更灵活，无需依赖消息本身的属性，适合生产者无法修改消息内容的场景。

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