可以在远程代理上获取队列列表吗？

Question

我正在尝试找出如何获取远程代理上现有队列的列表。

看起来我可以通过添加一条建议消息(我还没有实现)来监听队列的创建/销毁，但是我需要在启动时获取所有现有的队列。

看起来我可以用getDestinationMap做到这一点:

http://activemq.apache.org/maven/apidocs/org/apache/activemq/broker/region/Region.html#getDestinationMap()

但这似乎只能从嵌入式和进程内代理调用。

我的意思是。。。我愿意走这条路，但似乎更有意义的是，只为activemq设置正常的初始化/守护程序，然后让一个远程进程像普通的JMS使用者一样连接到它。

本文档似乎暗示这是可能的：

http://ActiveMQ . Apache . org/how-can-I-see-what-destinations-used . html

但是这是通过使用一个区域对象来实现的，而且只有当您和activemq在同一个JVM中时，这才是可能的。

Answer 1

看到这个答案：https://stackoverflow.com/a/14021722/3735747

如果您在Java中执行此操作，有DestinationSource类可以提供帮助：http://activemq.apache.org/maven/5.7.0/activemq-core/apidocs/org/apache/activemq/advisory/DestinationSource.html

创建连接并使用活动 MQ 连接类型，而不是 JMS 连接类型。

// Create a ConnectionFactory
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

// Create a Connection
ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection();

连接后，可以创建DestinationSource对象并获取队列：

DestinationSource ds = connection.getDestinationSource();
Set<ActiveMQQueue> queues = ds.getQueues();

for(ActiveMQQueue queue : queues){
    try {
        System.out.println(queue.getQueueName());
    } catch (JMSException e) {
        e.printStackTrace();
    }
}

Answer 2

    // Create a ConnectionFactory
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

// Create a Connection
ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection();


//Important point that was missed in the above answer
connection.start();

DestinationSource ds = connection.getDestinationSource();
Set<ActiveMQQueue> queues = ds.getQueues();

for(ActiveMQQueue queue : queues){
    try {
        System.out.println(queue.getQueueName());
    } catch (JMSException e) {
        e.printStackTrace();
    }
}