Azure Service Bus主题上的非持久JMS订阅

Question

我正在尝试使用JMS在Azure Service Bus上创建非持久主题订阅。此功能最近已用于高级服务总线层。

    @Bean
    public ConnectionFactory connectionFactory() {
        ServiceBusJmsConnectionFactorySettings connectionFactorySettings = new ServiceBusJmsConnectionFactorySettings();
        connectionFactorySettings.setConnectionIdleTimeoutMS(20000);
        return new ServiceBusJmsConnectionFactory("[CONN-STRING]", connectionFactorySettings);
    }

    @Bean
    public JmsListenerContainerFactory containerFactory(ConnectionFactory connectionFactory) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setSubscriptionDurable(false);
        factory.setPubSubDomain(true);
        return factory;
    }

   @JmsListener(destination = "mytopicName", containerFactory = "containerFactory")
   public void listenerMethod() {...} 

    @Bean
    public ConnectionFactory connectionFactory() {
        JmsConnectionFactory connFactory = new JmsConnectionFactory("amqps://servicebusurl");
        connFactory.setUsername(KEY NAME);
        connFactory.setPassword(KEY);
        return connFactory;
    }

Open of resource:(JmsConsumerInfo: { ID:anid, destination = topicname}) failed: The messaging entity 'servicebusname:Topic:topicname|qpid-jms:receiver:ID:theid' could not be found.

我知道连接本身不是问题，因为我可以用这个连接工厂在主题中发布。我想知道是否有义务使用服务总线连接工厂或是否有解决方案。

Answer 1

我查看了ServiceBusConnectionFactory是如何工作的，它使用了JMSConnectionFactory。它定制了JMSConnectionFactory的不同内容，所以我尝试以同样的方式定制它。起作用的是添加ConnectionFactory.SetExtension(jmsConnectionExtensions.amqp_open_properties.toString(),（connection,uri)->Map.of（“com.microsoft：is-client-provider”,true)

这使得侦听器使用连接工厂创建非持久的、非共享的主题订阅。