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);
Wir laufen über Programm in While-Schleife immer noch die gleichen Null-Antwort –