在Spring开机时动态修改@JMSListener destination

Question

我开发了一个@JMSListener，它可以从Java属性中获取目标，并且运行良好。

但现在我需要能够在运行时更改队列的“目的地”，而不必重置整个应用程序，即使在运行时修改属性，队列“目的地”也不会更改。

以下是我们如何实现@JMSListener：

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.support.converter.MessageConverter;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

@Component("b2b.CCRReceiver")
@Slf4j
public class CCRReceiver {

  //SOME_VARIABLES

    @Transactional
    @JmsListener(destination = "${tibco.configuration.queues.upsert}", containerFactory = "jmsFactory", concurrency = "${jms.concurrency}")
    public void receiveMessage(Message message) {
        //DO_SOME_STUFF
    }
}

如您所见，我第一次从一个值表达式中获得了目标，它运行良好，但我不知道如何访问JMSListener并更改其目标。

这能做到吗？有没有办法改变目的地？

或者我必须以允许我这样做的其他方式实现这个JMS侦听器？

Answer 1

我使用组件侦听器线程来解决这个问题。使用TaskExecutor和ApplicationContext进行管理。您可以在运行时创建。我还在努力。我也会试试加里·拉塞尔的建议。关于英语，我很抱歉。请随意更正。

applicationContext.getBean(ExampleListenerJMS.class);
... 
taskExecutor.execute(exampleListenerJMS);

类侦听器“实现Runnable， MessageListener”，其实现获取自定义连接管理器（Activemq服务器不同）。

@Component
@Scope("application")
public class ExampleListenerJMS implements Runnable, MessageListener {

private EspecificManagerJMS jms = new EspecificManagerJMS();

@Override
public void run() {
    customAndChekingActions();
}

protected void customAndChekingActions() {
...
    try {
        Destination destination = jms.getSession().createQueue(queue);
        MessageConsumer consumer = jms.getSession().createConsumer(destination);
        consumer.setMessageListener(this);
        ...
    } catch (JMSException e) {
        e.printStackTrace();
        ...
    }
}

@Override
public void onMessage(Message message) {
...
}

希望对你有所帮助

Answer 2

这应该有效：

>

自动连接JMSListerendpointRegistry（或以其他方式获取对它的引用）

<代码>注册表。getListenerContainer（“myListener”）。停止（）

<代码>注册表。getListenerContainer（“myListener”）。关机（）

（（AbstractMessageListenerContainer）registry.getListenerContainer（"myListener"））. setDestinationName（"newOne"）

<代码>注册表。getListenerContainer（“myListener”）。初始化（）

registry.getListenerContainer（"myListener"）. start（）；