如何使用@JMSListener暂停和开始使用消息

Question

我使用的是spring引导版本1.3.2。我正在使用@JMSListener从activemq获取我使用JMSTemplate创建/生成的消息。代码如下：

@JmsListener(destination = "myqueue")
public void consumeMsg(Object requestBody)
    try {
        javaMailSender.send(requestBody);
    } catch (MailException ex) {
        LOG.error(ex.getLocalizedMessage(), ex);
        if(ex.getMessage().contains(SMTP_CONNECTION_FAILURE) && activeMqMsg.getIntProperty("RETRYCOUNT") == 1) {
            producer.send("myqueue",requestBody)
        }
        else {
            producer.send("manualqueue",requestBody)
        }
    }
}

现在当从smtp出现连接失败错误时，我想暂停@JMSListener一段时间，然后重新开始使用消息。对于这个用例，我还没有看到使用@JMSListener的更好的例子。由于我使用的是spring boot，我在应用程序属性中添加了activemq连接参数，我不需要编写任何代码来创建连接工厂，设置队列...等等，你能帮助我们如何做到这一点吗？

Answer 1

获取对JMSListenerEndpointRegistrybean的引用（例如@autowire)并调用stop()-它将停止所有侦听器。start()将启动所有侦听器。

如果您有多个侦听器，并且只想停止1，则为其赋予id属性并使用Registry.GetListenerContainer(id)，然后停止/启动容器本身。