ACtiveMQ
에 메시지를 넣고 있습니다.이 메서드로 예제 프로그램을 실행하고 있습니다. ActiveMessageConsumer.receive(1000)
은 항상 null
메시지를 반환합니다. 대기열에 메시지가 있지만 여전히 해당 메시지를 수신 할 수 없습니다. url = "http : //";ActiveMQConsumer.receive (1000)가 null을 반환합니다.
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 루프에서 여전히 동일한 null 응답을 얻는 프로그램에서 실행 중입니다. –