topicJmsListenerContainerFactory是否支持异步处理-Azure Spring JMS？

Question

我试图从azure服务总线主题异步读取消息。我根据MS文档创建了JMS监听器

  @JmsListener(destination = TOPIC_NAME, containerFactory = "topicJmsListenerContainerFactory",
            subscription = SUBSCRIPTION_NAME)
    public void receiveMessage(User user) {
        logger.info("Received message: {}", user.getName());
    }

我需要确保topicJmsListenerContainerFactory容器工厂是否支持异步处理？

我尝试像下面这样实现DefaultJmsListenerContainerFactory，但是使用它我无法从服务总线顶部获取任何消息。它引发了一个异常，无法找到消息传递实体。我可以使用topicJmsListenerContainerFactory容器工厂获取消息

@Bean
@ConditionalOnMissingBean(name = "jmsListenerContainerFactory")
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(DefaultJmsListenerContainerFactoryConfigurer Configure, ConnectionFactory connectionFactory) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    Configure.configure(factory, connectionFactory);
    return factory;
}

https://docs.microsoft.com/en-us/java/api/com.azure.spring.autoConfigure.jms.servicebusJMSAutoConfiguration.topicJMSListenerContainerFactory？view=azure-java-preview

https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/jms/annotation/jmslistener.html

有谁能对此提出建议吗？

Answer 1

是的。有。快速浏览https://github.com/azure/azure-sdk-for-java/blob/e81850c3fceBe0bbfe65ed3e8a1c7c0c607798cf/sdk/spring/azure-spring-boot/src/main/java/com/azure/spring/autoconfiguration/jms/servicebusjmsautoconfiguration.java#l71

提供TopicJMSListenerContainerFactory也是DefaultJMSListenerContainerFactory类的一个实例，正如我们所知DefaultJMSListenerContainerFactory提供了Spring JMS的所有优点，所以它应该可以正常工作。