spring-jms选择器不适用于servicebus。

Question

我用的是弹簧和天蓝色的服务巴士。我试图使用选择器来区分消息类型，但是我无法让它工作。这是我的密码。

@Component
@Slf4j
public class MessageTestRunner implements CommandLineRunner {

    private static final String QUEUE_NAME = "lva-test-queue";
    private static final String PING_SELECTOR = "selector = 'PING'";
    private static final String PONG_SELECTOR = "selector = 'PONG'";

    private static final String SB_SCHEDULED_ENQUEUE_HEADER = "x-opt-scheduled-enqueue-time";


    private final JmsTemplate jmsTemplate;

    public MessageTestRunner(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    @Override
    public void run(String... args) throws Exception {
        jmsTemplate.convertAndSend(QUEUE_NAME, ping(), m -> {
            m.setStringProperty("selector", "PING");
            return m;
        });
        jmsTemplate.convertAndSend(QUEUE_NAME, pong(), m -> {
            m.setStringProperty("selector", "PONG");
            return m;
        });
    }

    private PingMessage ping() {
        final PingMessage msg = new PingMessage();
        msg.setAt(ZonedDateTime.now());
        return msg;
    }

    private PongMessage pong() {
        final PongMessage msg = new PongMessage();
        msg.setAt(ZonedDateTime.now());
        return msg;
    }


    @JmsListener(destination = QUEUE_NAME, selector = PING_SELECTOR, containerFactory = JMS_FACTORY_NAME)
    public void handle(PingMessage message) {
        log.debug("Handling ping message [{}]", message);
    }

    @JmsListener(destination = QUEUE_NAME, selector = PONG_SELECTOR, containerFactory = JMS_FACTORY_NAME)
    public void handle(PongMessage message) {
        log.debug("Handling pong message [{}]", message);
    }

}

这是我得到的例外

org.springframework.jms.listener.adapter.ListenerExecutionFailedException: Listener method could not be invoked with incoming message
Endpoint handler details:
Method [public void com.example.MessageTestRunner.handle(com.example.data.model.PingMessage)]
Bean [com.example.MessageTestRunner@7aae1170]
; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [com.example.data.model.PongMessage] to [com.example.data.model.PingMessage] for org.springframework.jms.listener.adapter.AbstractAdaptableMessageListener$MessagingMessageConverterAdapter$LazyResolutionMessage@72eb85b7, failedMessage=org.springframework.jms.listener.adapter.AbstractAdaptableMessageListener$MessagingMessageConverterAdapter$LazyResolutionMessage@72eb85b7
    at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:118) ~[spring-jms-5.3.10.jar:5.3.10]
    at org.springframework.jms.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:77) ~[spring-jms-5.3.10.jar:5.3.10]
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:736) ~[spring-jms-5.3.10.jar:5.3.10]
    at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:696) ~[spring-jms-5.3.10.jar:5.3.10]
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:674) ~[spring-jms-5.3.10.jar:5.3.10]
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:318) ~[spring-jms-5.3.10.jar:5.3.10]
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:257) ~[spring-jms-5.3.10.jar:5.3.10]

有没有配置/..。我应该更改哪一个来启用选择器？

编辑：问题似乎是当我禁用发送PONG消息时，PONG处理程序也接收到PING消息，并且我可以在日志中看到错误。但是，我希望PING消息永远不会发送到乒乓处理程序，因为有选择器不允许这样做。

EDIT2:似乎只支持服务总线高级层中的选择器，后者支持JMS2.0 (链接)

Answer 1

因此，问题在于服务总线本身。我们在不支持选择器的标准层中使用服务总线。更详细的这里和这里