ActiveMQConsumer.receive(1000)返回null

问题描述 投票:-1回答:2

我们正在向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);
spring jms activemq
2个回答
0
投票

您的ActiveMQ URL应该是以下之一:http://activemq.apache.org/connection-configuration-uri.html

例如:tcp:// localhost:61616


0
投票

https://issues.apache.org/jira/browse/AMQ-6823

AMQ 5.12.3存在错误,使用5.15.1解析了http连接器

© www.soinside.com 2019 - 2024. All rights reserved.