我正在使用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
谁能帮我解决?谢谢!
也许您发送的队列或主题在服务器上不存在,并且您的客户端没有创建权限。