问题描述
所以问题是如何使用休假方式临时停止和启动使用spring创建的jms侦听器:
So question is how to temporary stop and start a jms listener created using spring using the fallowing way :
<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"/>
那么基本上是什么问题.我们确实有一个init/update机制，客户端可以在任何时间运行，并且在此init/update期间我想停止使用任何消息，因为此时系统无法使用，并且如果出现消息，它将丢失.
So basically what is the problem. We do have an init/update mechanism that the client can run in any time and durring this init/update I want to stop consuming of ANY messages because the system is unusable in this time and if a message came it will be lost.
因此，如何使用API停止侦听器或侦听器容器或整个连接.我发现一个类AbstractJmsListeningContainer具有停止/启动功能，但是我如何获取呢?我的意思是这些jms都不是:侦听器和侦听器容器都没有名称或类似名称.
So how I can stop the listener or the listener container or the whole connection using the API. I found that a class AbstractJmsListeningContainer have stop/start but how I can get it ? I mean none of this jms: listener and listener-containers have a name or anything like that.
推荐答案
您可以为监听器-容器分配一个ID.然后通过调用getBean或注入它来获取对它的引用.这将为您提供一个AbstractJmsListeningContainer，您可以在其上调用start/stop.
You can assign an id to the listener-container. Then get a reference to it, either by calling getBean or getting it injected. This will give you a AbstractJmsListeningContainer on which you can call start / stop.
这篇关于使用Spring启动和停止JMS侦听器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！