JMS容器工厂手动启动

Question

我有一个通过注释配置的 Spring JMS 应用程序，我试图在 JMS 侦听器启动之前向应用程序提供一些信息。之后，我想手动启动监听器。

使用以下配置：

@Bean(name = "queueContainerFactory")
public JmsListenerContainerFactory<?> queue(ConnectionFactory cf) {
        SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
        ActiveMQConnectionFactory amqCf = (ActiveMQConnectionFactory) cf;
        factory.setConnectionFactory(amqCf);
    ...
}

我看到了选项：factory.setAutoStartup(FALSE);

这样，应用程序上下文启动，@JmsListener 没有启动，但我不知道如何手动启动 JMS 容器工厂。

@JmsListener(containerFactory="queueContainerFactory", destination = "${destination}")
    public void jmsListener(String message) {
...
}

Answer 1

您必须自动连接JmsListenerEndpointRegistry 并通过其id 获取特定的MessageListenerContainer。其中id可以在@JmsListener上配置：

/**
 * The unique identifier of the container managing this endpoint.
 * <p>If none is specified, an auto-generated one is provided.
 * @see org.springframework.jms.config.JmsListenerEndpointRegistry#getListenerContainer(String)
 */
String id() default "";

可能看起来像：

@JmsListener(id ="myContainer", 
           containerFactory="queueContainerFactory", 
           destination = "${destination}")
    public void jmsListener(String message) {
...
}

...

@Autowired
JmsListenerEndpointRegistry jmsListenerEndpointRegistry;

...

this.jmsListenerEndpointRegistry.getListenerContainer("myContainer").start();