2017-12-16 10 views
-1

Wir setzen Nachricht in ACtiveMQ, wir führen Beispielprogramm mit dieser Methode ActiveMessageConsumer.receive(1000) immer zurück null Nachricht. Auch wenn die Warteschlange Nachrichten enthält, können diese Nachrichten immer noch nicht empfangen werden. URL = "http: //";ActiveMQConsumer.receive (1000) gibt null zurück

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

Wir laufen über Programm in While-Schleife immer noch die gleichen Null-Antwort –

Antwort

0

Ihre ActiveMQ URL sollte einer von diesen sein: http://activemq.apache.org/connection-configuration-uri.html

Zum Beispiel: tcp: // localhost: 61616

+0

Nein, wir können auch http/https verwenden, damit funktionierte es, aber jetzt mit 5.12.3 funktioniert es nicht. –

+0

Ok, ich sehe - Sie verwenden den HTTP-Tunnel-URI mit "http: // host: port". Ich nehme an, du hast deinen Namen in der Warteschlange bestätigt und wie genau siehst du Nachrichten in ActiveMQ? –

+0

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