Spring 4.1@JmsListener配置

Question

我想为需要JMS侦听器的应用程序使用Spring 4.1中提供的新注释和功能。

我已经仔细阅读了Spring 4.1 JMS改进帖子中的注释，但我仍然错过了@JmsListener和DestinationResolver之间的关系，以及我将如何设置应用程序以指示正确的目标或endpoint。

以下是@JmsListener的建议使用

@Component
public class MyService {

    @JmsListener(containerFactory = "myContainerFactory", destination = "myQueue")
    public void processOrder(String data) { ... }
}

现在，我不能在我的实际代码中使用它，因为“myQueue”需要使用Environment.get属性（）从配置文件中读取。

我可以使用DestinationResolver设置适当的myContainerFactory，但大多数情况下，如果您不需要JNDI在应用服务器中查找队列并且不需要执行一些自定义回复逻辑，您似乎只需使用DynamicDestinationResolver。我只是想了解Spring希望我如何使用@JmsListener注释以参数化方式指示队列的名称。

在博客文章的后面，我找到了对这个配置器的引用：

@Configuration
@EnableJms
public class AppConfig implements JmsListenerConfigurer {

@Override
public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
    registrar.setDefaultContainerFactory(defaultContainerFactory());

    SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
    endpoint.setDestination("anotherQueue");
    endpoint.setMessageListener(message -> {
        // processing
    });
    registrar.registerEndpoint(endpoint);
}

现在，这有一定的意义，我可以看到这允许我在运行时从一些外部字符串设置目的地，但这似乎与使用@JmsListener相冲突，因为它似乎覆盖了上面代码中有利于endpoint.setMessageListener的注释。

关于如何使用JmsListener指定适当的队列名称，有什么提示吗？

Answer 1

您现在最终可以这样做，但这有点复杂。您可以使用JmsListenerConfigrer设置自定义JmsListenerEndpoint注册表

@Configuration
@EnableJms
public class AppConfig implements JmsListenerConfigurer {

    @Override
    public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
        registrar.setEndpointRegistry(customRegistry());
    }

}

然后重写registerListenerContainer方法，类似于

public void registerListenerContainer(JmsListenerEndpoint endpoint, JmsListenerContainerFactory<?> factory) {
    // resolve destination according to whatever -> resolvedDestination
    ((AbstractJmsListenerEndpoint)endpoint).setDestination(resolvedDestination);
    super.registerListenerContainer(endpoint, factory);
}

但我们可以做得更好。请观看/投票SPR-12280

Answer 2

如果人们在spring boot中使用JmsListener，则不必配置PropertySourcesplaceConfigurer。它是现成的

样品：

类

@JmsListener(destination = "${spring.activemq.queue.name}")
    public void receiveEntityMessage(final TextMessage message) {
    // process stuff 
}
}

应用属性

spring.activemq.queue.name=some.weird.queue.name.that.does.not.exist

Spring防尘套输出

[26-Aug;15:07:53.475]-[INFO ]-[,]-[DefaultMes]-[o.s.j.l.DefaultMessageListenerContainer ]-[931 ]-Successfully refreshed JMS Connection 
[26-Aug;15:07:58.589]-[WARN ]-[,]-[DefaultMes]-[o.s.j.l.DefaultMessageListenerContainer ]-[880 ]-Setup of JMS message listener invoker failed for destination 'some.weird.queue.name.that.does.not.exist' - trying to recover. Cause: User user is not authorized to read from some.weird.queue.name.that.does.not.exist 
[26-Aug;15:07:59.787]-[INFO ]-[,]-[DefaultMes]-[o.s.j.l.DefaultMessageListenerContainer ]-[931 ]-Successfully refreshed JMS Connection 
[26-Aug;15:08:04.881]-[WARN ]-[,]-[DefaultMes]-[o.s.j.l.DefaultMessageListenerContainer ]-[880 ]-Setup of JMS message listener invoker failed for destination 'some.weird.queue.name.that.does.not.exist' - trying to recover. Cause: User user is not authorized to read from some.weird.queue.name.that.does.not.exist 

这证明了@JmsListener能够从application.properties中提取属性值，而无需实际设置任何显式的属性

我希望这有帮助！

Answer 3

另请注意，根据用例，您已经可以使用每个环境和PropertySourcesplaceConfigurer的属性文件进行参数化

@JmsListener(destinations = "${some.key}")

按https://jira.spring.io/browse/SPR-12289