gpt4 book ai didi

spring - 如何停止/启动 spring DefaultMessageListenerContainer?

转载 作者:行者123 更新时间:2023-12-02 02:17:46 32 4
gpt4 key购买 nike

我开发了使用 Spring JMS 的项目来接收来自队列的消息。并部署Websphere应用服务器(WAS 7.5)集群环境。一旦部署到服务器中,它就工作正常。后来我更新了记录器信息并部署到服务器中。看来服务器没有选择最新的代码库。即使我已经停止/启动集群。

请引用下面的配置xml。

<bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
<property name="hostName" value="${hostName}"/>
<property name="port" value="${port}"/>
<property name="queueManager" value="${queueManager}"/>
<property name="transportType" value="${transportType}"/>
<property name="channel" value="${channel}"/>
</bean>

<jms:listener-container container-type="default"
connection-factory="connectionFactory" acknowledge="auto" concurrency="5" >
<jms:listener destination="DEV.TESTQUEUE" ref="jmsMessageListener"
</jms:listener-container>

<bean id="jmsMessageListener" class="JmsMessageListener"/>


public class JmsMessageListener implements MessageListener {

public void onMessage(Message message) {

}
}
Could you please advise how to stop/start the container? 

最佳答案

这是我的解决方案:

final Map<String, DefaultMessageListenerContainer> containers = ctx.getBeansOfType(DefaultMessageListenerContainer.class);
if (containers != null && !containers.isEmpty()) {
for (DefaultMessageListenerContainer container : containers.values()) {
container.stop();
}
}

关于spring - 如何停止/启动 spring DefaultMessageListenerContainer?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28786301/

32 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com