java - 为什么使用 jmstemplate 时报告的 activemq 队列数量发生变化？

Question

使用JmsTemplate获取activemq队列列表时，报出的队列数量变化

 private Set<String> queues = new HashSet<>();

     try(ActiveMQConnection connection = (ActiveMQConnection) 
      jmsTemplate.getConnectionFactory().createConnection()){
            connection.start();

            for(ActiveMQQueue queue : connection.getDestinationSource().getQueues()){
                queues.add(queue.getQueueName());
            }

            queues.remove(defaultReplyToQueue);

            log.info("findAllQueues found {}", queues.size());
            return queues;
        }

Answer 1

由于给出的细节有限，很难完全回答这个问题，但我猜问题归根结底是队列在目标源中的填充方式。当代理枚举现有队列时，它们以异步方式到达。这意味着仅打开连接并立即请求所有队列可能会报告随机结果，因为并非所有队列都已从代理到达。