0

我正在使用 Qpid 协议向 ActiveMQ Artemis 的队列发送一条消息,如果我使用以下可以成功的代码

ConnectionFactory connectionFactory = new JmsConnectionFactory("amqp://localhost:5672");

但是当我使用这种方式时会失败:

Context initialContext = new InitialContext();
factory = (ConnectionFactory) initialContext.lookup("ConnectionFactory");

下面的代码是 jndi.properties:

java.naming.factory.initial=org.apache.qpid.jms.jndi.JmsInitialContextFactory
connectionFactory.ConnectionFactory=amqp://localhost:5672
queue.queue/myqueue=otd-aps

谁能帮我解决它?谢谢!

4

1 回答 1

0

也许您发送的队列或主题在服务器上不存在,并且您的客户端没有创建权限。

于 2018-06-22T17:42:28.763 回答