通过JNDI使用ActiveMQ

Question

我正在尝试使用JNDI创建与ActiveMQ的简单连接。

我有

1. 队列名为“ example.A”。

2. 根据接触JNDI的ActiveMQ文档，如果我想通过JNDI使用ConectionFactories和Queues（主题），则必须将jndi.properties文件放在我的类路径中。据我了解，默认情况下，activeMQ类路径是％activemq％/ conf目录。我没有改变。所以我的队列有这个属性：

queue.MyQueue = example.A

1. 我为ActiveMQ创建了Java客户端类，该类使用JNDI如下：

       Properties jndiParameters = new Properties() ;
   jndiParameters.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
   jndiParameters.put(Context.PROVIDER_URL, "tcp://localhost:61616");
   Context context = new InitialContext(jndiParameters);
   ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");
   Queue queue = (Queue) context.lookup("MyQueue");
   

但找不到我的队列，它引发异常：javax.naming.NameNotFoundException：MyQueue

我的错误在哪里？

Answer 1

问题是您要显式创建属性并将它们传递给InitialContext构造函数。这意味着将不会读取类路径上的jndi.properties。

您的代码应类似于：

Context context = new InitialContext();
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");
Queue queue = (Queue) context.lookup("MyQueue");