向使用camel创建的Activemq队列发送消息

Question

我是activeMQ的新手，在将消息从驻留在另一台服务器上的消息生成器推送到activeMQ定义的队列时遇到问题。

我在activeMQ上使用camel routes创建的应用程序中有几个队列。我尝试从另一台服务器上的应用程序对这些队列执行远程JNDI查找。我使用了来自http://activemq.apache.org/jndi-support.html页面的activemq文档片段。

我可以连接到activeMQ，但是我无法查找使用camel routes定义的队列。

队列消费者是通过下面定义的camel路由创建的。from（“jms:queue:APP.IF.jms.OUTBOUND”）../。

但是我没有在下面执行的查找中看到此队列 -

    String destination = "APP.IF.JMS.OUTBOUND";
    ConnectionFactory cf = null;
    Destination dest = null;
    Context ctx = null;
    Properties params = new Properties();
    readProperty(params, Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory", false);
    readProperty(params, Context.PROVIDER_URL, "tcp://localhost:61616", false);
    readProperty(params, "queue.AS.IF.JMS.REQUEST",
     "AS.IF.JMS.REQUEST", false);

    ctx = new InitialContext(params);
    cf = (ConnectionFactory) ctx.lookup("ConnectionFactory");
    System.out.println(ctx.getEnvironment());
    dest = (Destination) ctx.lookup(destination);
    ..............

在此队列上完成查找时，最后一行将失败。我确实在控制台上看到了这一点。我是否缺少一些配置来在 JNDI 上公开此队列？感谢您的回复。

Answer 1

将PROVIDER_URL中的单词localhost改为machineName。既然是远程操作，就需要你的机器名。