ActiveMQ：队列查找问题

Question

我已经按照documentation 中的描述在activemq.xml（ActiveMQ 5.2.0 版）中配置了一个队列。

<destinations>
    <queue physicalName="FOO.BAR" />
    <queue physicalName="DUMMY" />
</destinations>

我正在尝试使用以下代码从 java（在同一主机上）访问它：

Hashtable properties = new Hashtable();
properties.put(Context.INITIAL_CONTEXT_FACTORY, 
    "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
properties.put(Context.PROVIDER_URL, "tcp://localhost:61616");

context = new InitialContext(properties);

factory = (ConnectionFactory) context.lookup("ConnectionFactory");
connection = factory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
queueName = "DUMMY"; // which can be either FOO.BAR or DUMMY
dest = (Destination) context.lookup(queueName);

我收到以下错误，尽管队列在 jconsole (Tree / org.apache.activemq / Queue) 中可见：

javax.naming.NameNotFoundException: DUMMY

请告诉我我做错了什么。非常非常感谢！

Answer 1

首先，您不必explicitly create any queues in the broker，尽管它没有害处。

此外，代理中可用的目的地也不会使用某种 JNDI 名称自动映射到 JNDI 上下文中。

您可以这样做explicitly as described here。如果您想要 JNDI 的自动神奇填充，请使用 dynamicQueues/DUMMY 的 JNDI 命名约定作为您查找的 JNDI 名称（如 Dynamically creating destinations 中所述）

Answer 2

嗯..当我想听队列时，我通常会做这样的事情。 （从 javax.jms 导入）

队列队列；

    // Connect to ActiveMQ
    ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(messageBrokerURL);
    connection = factory.createConnection();
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    // List to Dummy Queue
    queue = session.createQueue("DUMMY");
    messageConsumer = session.createConsumer(queue);
    messageConsumer.setMessageListener(queueHandler);

    // Start the connection
    connection.start();

并确保您的 Handler 实现 MessageListener。