【发布时间】:2018-05-30 16:07:30
【问题描述】:
我们正在将消息放入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);
【问题讨论】:
-
我们在while循环中运行上面的程序仍然得到相同的空响应