使用Spring启动和停止JMS监听器

Question

所以问题是如何临时停止和启动使用spring创建的jms侦听器，使用衰减方式：

<amq:connectionFactory id="exampleJmsFactory" brokerURL="tcp://${jms.broker.url}" />

<jms:listener-container concurrency="1" connection-factory="exampleJmsFactory"  destination-type="queue" message-converter="exampleMessageConverter">
        <jms:listener destination="incoming.example.client.queue" ref="exampleProductsMessageConsumer" method="consume"/>
</jms:listener-container>


<bean id="exampleProductsMessageConsumer" class="com.unic.example.jms.receive.JmsExampleProductsMessageConsumer" scope="tenant"/>

那么基本上问题是什么。我们确实有一个初始化/更新机制，客户端可以在任何时间运行，在初始化/更新期间，我想停止使用任何消息，因为系统在这段时间内不可用，如果消息来了，它将丢失。

因此，我如何使用API停止侦听器或侦听器容器或整个连接。我发现一个类AbstractJmsListeningContainer有stop/start，但我怎么能得到它呢？我的意思是这些jms都没有：侦听器和侦听器容器都有名称或类似的名称。

Answer 1

您还可以获取消息ListenerContainer，并在其上调用Stop（）：

@javax.annotation.Resource //autowire by name
 private AbstractJmsListeningContainer myMessageListenerContainer;

 myMessageListenerContainer.stop();

 I'm using the more verbose setup of this container:
 <bean id="myMessageListenerContainer" class="org.springframework.jms.listener.DefaultMes sageListenerContainer">
 <property name="connectionFactory" ref="jmsConnectionFactory"/>
 <property name="destination" ref="myQueue"/>
 <property name="messageListener" ref="myListener"/>
 <property name="autoStartup" value="true" />
 </bean>

在这里，您可以看到，如果您不希望listenerContainer自动启动，您可以将autoStartup设置为false。

Answer 2

是的，这就是诀窍。

<jms:listener-container concurrency="1" connection-factory="exampleJmsFactory"  destination-type="queue" message-converter="exampleMessageConverter">
        <jms:listener id="exampleProductsMessageListener" destination="incoming.example.client.queue" ref="exampleProductsMessageConsumer" method="consume"/>
</jms:listener-container>



DefaultMessageListenerContainer exampleProductsMessageListener= Registry.getApplicationContext().getBean("exampleProductsMessageListener", DefaultMessageListenerContainer.class);
exampleProductsMessageListener.stop();

Answer 3

您可以为侦听器容器分配一个id。然后通过调用getBean或注入它来获取对它的引用。这将为您提供一个AbstractJmsListeningContainer，您可以在其上调用start/Stop。