SpringJMS - 如何断开 MessageListenerContainer

Question

我想断开队列的

DefaultMessageListenerContainer

。我正在使用

dmlc.stop()

，

dmlc.shutdown()

。连接时，5 个消费者线程连接到队列。当我尝试断开连接时，4 个消费者已断开连接，但 1 个消费者仍保持连接。

环境

1. ActiveMQ 与 AMQP
2. Spring JMS 与 Apache Qpid

问题 调用 destroy 和 stop 方法后，仍然有一个消费者连接到队列。

所需解决方案

我想知道，如何干净地断开与队列的零消费者连接的

MessageListenerContainer

。

配置和代码

    @Bean
    public DefaultMessageListenerContainer getMessageContainer(ConnectionFactory amqpConnectionFactory, QpidConsumer messageConsumer){
        DefaultMessageListenerContainer listenerContainer = new DefaultMessageListenerContainer();
        listenerContainer.setConcurrency("5-20");
        listenerContainer.setRecoveryInterval(jmsRecInterval);
        listenerContainer.setConnectionFactory(new CachingConnectionFactory(amqpConnectionFactory));
        listenerContainer.setMessageListener(messageConsumer);
        listenerContainer.setDestinationName(destinationName);
        return listenerContainer;
    }

    private void stopListenerIfRunning() {
            DefaultMessageListenerContainer dmlc = (DefaultMessageListenerContainer) ctx.getBean("messageContainer");
            if (null != dmlc) {
                if(!dmlc.isRunning()){return;}
                dmlc.stop(new Runnable() {
                    @Override
                    public void run() {
                        logger.debug("Closed Listener Container for Connection {}", sub.getQueueName());
                        if (sub.getSubscriptionStatus() == SubscriptionStatus.DELETED
                                || sub.getSubscriptionStatus() == SubscriptionStatus.SUSPENDED_DELETE) {
                            listenerHandles.remove(sub.getQueueName());
                        }
                    }
                });
                dmlc.destroy();
                dmlc.shutdown();
            }
        }
    }

Answer 1

listenerContainer.setConnectionFactory(newCachingConnectionFactory(amqpConnectionFactory));

你需要摧毁

CachingConnectionFactory

。

您通常不需要带有侦听器容器的缓存工厂，因为会话是长期存在的；如果你有可变的并发性，你绝对不应该这样做；来自javadocs...

 * <p><b>Note: Don't use Spring's {@link org.springframework.jms.connection.CachingConnectionFactory}
 * in combination with dynamic scaling.</b> Ideally, don't use it with a message
 * listener container at all, since it is generally preferable to let the
 * listener container itself handle appropriate caching within its lifecycle.
 * Also, stopping and restarting a listener container will only work with an
 * independent, locally cached Connection - not with an externally cached one.

如果您希望缓存连接，请使用

SingleConnectionFactory

或在 CCF 上调用

setCacheConsumers(false)

。