Azure Service Bus消息选择器失效问题求助（AMQP）

问题还原 #

使用Jakarta JMS发送消息，Qpid JMS作为监听器对接Azure Service Bus时，明明设置了基于JMSCorrelationID的消息选择器，监听器却还是会接收队列里的所有消息，完全起不到过滤作用。相关代码如下：

String selector = "JMSCorrelationID = '" + correlationId + "'";
MessageConsumer consumer = session.createConsumer(queue, selector); 

排查方向与解决办法 #

1. 换用Service Bus原生属性名写选择器 #

Azure Service Bus会把JMS标准属性映射成自身的系统属性，JMSCorrelationID对应的就是Service Bus的CorrelationId。Qpid JMS客户端直接用JMS属性名写选择器时，Service Bus可能无法识别，导致过滤失效。

改成用Service Bus原生属性名：

String selector = "CorrelationId = '" + correlationId + "'";
MessageConsumer consumer = session.createConsumer(queue, selector);

2. 检查Qpid JMS客户端版本 #

部分旧版本的Qpid JMS客户端存在属性映射bug，不会自动把JMS标准属性转换为Service Bus对应的属性名。建议升级到最新稳定版，这类兼容性问题通常会在新版本中修复。

3. 确认消息发送时的属性设置 #

发送消息时要确保JMSCorrelationID确实被正确赋值，没有被后续逻辑覆盖。可以在发送前打印消息属性，或者通过Azure Portal查看队列中消息的CorrelationId值，确认和你设置的correlationId完全一致。

示例发送代码参考：

Message message = session.createTextMessage("test content");
message.setJMSCorrelationID("target-correlation-id");
producer.send(message);

4. 排查队列特殊配置影响 #

如果使用的是Service Bus的分区队列或会话队列，部分配置可能会影响选择器的生效逻辑。比如会话队列中，选择器需要和会话ID的逻辑兼容，建议先切换到普通队列测试，确认是否是配置导致的问题。

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