我正在使用 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
谁能帮我解决它?谢谢!