2017-12-16 5 views
-1

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); 
+0

while 루프에서 여전히 동일한 null 응답을 얻는 프로그램에서 실행 중입니다. –

답변

0

귀하의 ActiveMQ URL은 다음 중 하나 여야합니다 : 예를 들어 http://activemq.apache.org/connection-configuration-uri.html

: TCP : // localhost를 : 61,616

+0

아니요, http/https도 사용할 수 있습니다. 작동하지만 5.12.3에서는 작동하지 않습니다. –

+0

알았어, 나는 본다 - "http : // host : port"와 함께 HTTP 터널 URI를 사용한다. 큐 이름을 확인하고 ActiveMQ 내부의 메시지가 정확히 어떻게 표시됩니까? –

+0

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

관련 문제