Wie man alle Nachrichten in die Warteschlange eingereiht in ActiveMQ?
Ich bauen möchte, eine einfache consumer-Programm (in java), um alle Nachrichten bestückt, in die eine ActiveMQ-Thema.
Ich habe einen Produzenten, der die Kurzmitteilung senden, in die Warteschlange.
Aber ich weiß nicht wie ich anfangen zu schreiben, meine Verbraucher, die für das abrufen von alten Nachrichten und warten auf neue.
Falls Sie noch ein Beispiel, danke!
Dies ist mein Produzent: http://pastebin.com/uRy9D8mY
Dies ist meine Verbraucher: http://pastebin.com/bZh4r66e
Wenn ich mit meinem Produzenten vor meinem Verbraucher, führen die Verbraucher, habe ich nichts.
Wenn ich meine Verbraucher dann mein Produzent, ich hinzufügen, 72 Nachrichten in der Warteschlange, aber meine Verbraucher erhielten nur 24 Nachricht...
Du musst angemeldet sein, um einen Kommentar abzugeben.
Empfehle ich dieses tutorial (wie Apache ActiveMQ) SONNE Jms-tutorial
Gibt es viele Möglichkeiten, zu schreiben, JMS/ActiveMQ von Programmen, mit verschiedenen frameworks wie Spring, oder durch die Verwendung von einfachen java.
Im wesentlichen schreiben Sie eine listener-Klasse wie folgt aus:
Da Sie bereits produzieren Meldung, ich nehme an, Sie haben die Verbindung und läuft.
Dann gibt es einige Fehler-handling-code in diesem Beispiel nicht enthalten, aber Sie sollten in der Lage sein, um es herauszufinden, mit der Hilfe von dem tutorial und JMS-Dokumentation.
Mit dem unten angegebenen code können Sie Lesen, alle Nachrichten, die en-in der Warteschlange in der Warteschlange.
die Nachrichten in der Warteschlange.
die Schleife.
Wenn Sie einen unendlichen Verbraucher, die alle Botschaften Lesen, wenn neu in die Warteschlange, dann entfernen Sie den else-Teil, also das Programm wird nicht beendet.
Hoffe, das Verbraucher-Programm hilft den Menschen, die neu waren zu ActiveMQ.