我们正在向ACtiveMQ
发送消息,我们正在使用此方法运行示例程序ActiveMessageConsumer.receive(1000)
始终返回null
消息。即使Queue有消息,仍然无法接收这些消息。 url =“http://”;
connectionFactory = new ActiveMQConnectionFactory("admin", "xxxxx", url);
connection = connectionFactory.createConnection();
((ActiveMQConnection)connection).getPrefetchPolicy().setQueuePrefetch(0);
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue("something.sampleQ");
MessageConsumer consumer = session.createConsumer(destination);
ActiveMQObjectMessage message = (ActiveMQObjectMessage) consumer.receive(1000);
您的ActiveMQ URL应该是以下之一:http://activemq.apache.org/connection-configuration-uri.html
例如:tcp:// localhost:61616
https://issues.apache.org/jira/browse/AMQ-6823
AMQ 5.12.3存在错误,使用5.15.1解析了http连接器