Apache ActiveMQ ist ein Open Source-Nachrichtenbroker (Apache 2.0-lizenziert), der den Java Message Service 1.1 (JMS) vollständig implementiert. Es bietet "Unternehmensfunktionen" wie Clustering, mehrere Nachrichtenspeicher und die Möglichkeit, jede Datenbank als JMS-Persistenzanbieter neben VM-, Cache- und Journalpersistenz zu verwenden.

Mehr über activemq...

Ich bin sehr neu in Activemq und ich versuche zu verstehen, ob ich Folgendes erreichen kann: Ich habe einen Produzenten, der Nachrichten an Broker veröffentlicht. 1. In einem sicheren Netzwerk gibt es einen Broker 2 und den Empfänger. Die Verbindung zwischen Broker 1 und Broker 2 kann nur in Richtun....
31 Mai 2021 im 14:57
Ich weiß nicht, ob es möglich ist oder nicht, und ich habe es googelt, ich habe dafür keine konkrete Lösung gefunden. Ich habe ein Szenario, um zu implementieren, wo ich das PUB / SUB-Modell verwenden muss, um zu verstehen, welche Änderungen auf bestimmten DB2-Tischen vorgenommen werden. Wenn also d....
30 Mai 2021 im 09:20
Ich habe eine Art Black-Box-Anwendung, da es vom Verkäufer entwickelt wurde. Ich könnte alle Themen und Warteschlangen sehen, wenn ich mich mit dieser URL als Remote-Prozess localhost:35099 an JCONSOLE anmelde, aber ich sehe das ActivemQ-Installationsverzeichnis jedoch nicht. Gibt es eine Möglichkei....
27 Mai 2021 im 09:33
Erstens habe ich ein Testprojekt, um mit Activemq zu lernen. Alles hat dort gearbeitet. Aber wenn ich das Gleiche mit eine bereits getroffene Anwendung auf der Spring + Security + Jaas anhält, dann ist alles aufgehört zu arbeiten, Und anscheinend funktioniert die Klasse JmsListener nicht. Ich habe N....
20 Mai 2021 im 09:36
Gibt es einen maximalen stützlichen Wert von scheduledmessage.amq_Scheduled_delay ?Wir betrachten eine Verzögerung zwischen 48 Stunden und einer Woche und ich kann keinen dokumentierten Wert finden, der maximal ist. Ich weiß, dass ein {long einen ausreichend Wert, aber ich weiß nicht, ob es intern....
13 Mai 2021 im 21:59
Ich habe den Beispielcode auf Go-Amp-Paket readme, aber ich wollte eine Verbindung herstellen zu einem Thema und keine Warteschlange, wie in dem Beispielcode auf dieser Readme ab heute in dem Beispielcode angezeigt. Was ich getan habe, war, nur den Themensatennamen zu setzen, in dem der "Warteschlan....
11 Mai 2021 im 20:40
Ich arbeite mit Activemq. Ich möchte GRPC-Anrufe als Nachricht in ActivEMQ eingeben. Sobald der Verbraucher eine Nachricht ausgibt, sollte der GRPC in der Nachricht ausgeführt werden. GRPC-Anrufe nehmen Parameter ein, sodass ich verstehen möchte, wie diese Parameter zusammen mit dem Methodennamen / ....
11 Mai 2021 im 16:19
Ich habe einen einfachen Verbraucher: try { factory = new NMSConnectionFactory(Settings.Endpoint); connection = factory.CreateConnection(Settings.UserName, Settings.Password); connection.ClientId = Settings.Name; ....
22 Apr. 2021 im 22:51
Ich habe ein Problem beim Schreiben eines Basistests, bei dem eine Nachricht in einer Punkt-Punkt-Warteschlange veröffentlicht wird. Bei Verwendung einer @JmsListener Bean wird die Nachricht verbraucht. Wenn Sie kein @JmsListener und keinen Verbraucher verwenden, der vom connectionFactory über das ....
2 März 2021 im 19:55
Ich möchte einen kleinen Integrationsmikroservice entwickeln, der die Kommunikation zwischen zwei vorhandenen Systemen implementiert. System A enthält Apache Kafka-Themen, mit denen Nachrichten erstellt und verarbeitet werden. System B verfügt über eine REST-API und kann REST-API-Rückrufe aufrufen. ....
Gibt es ein funktionierendes Quellcodebeispiel für Spring AMQP + ActiveMQ (Sender + Empfänger) ohne Abhängigkeit von der JMS-API? Hinweis: Der Grund für diese Frage ist, dass Spring bereits listet JMS als veraltetes Transportprotokoll für Remoting auf (nur AMQP- und Webdienstaufrufe werden noch akti....
25 Feb. 2021 im 08:18
Auf dem CentOS-Computer arbeitet ein ActiveMQ-Server. Mit dem OpenWire JMS-Client kann ich Nachrichten mit TCP und HTTP verbinden und verarbeiten. Wenn ich es jedoch mit dem ActiveMQ-Test-STOMP-Client versucht habe, wird diese Ausnahme auf connection.receieve ausgelöst. java.net.SocketTimeoutExcep....
12 Feb. 2021 im 18:42
Ich bin so festgefahren. Ich möchte ein ActiveMQ-Thema abonnieren. ActiveMQ funktioniert auf dem Centos-Computer NOT LOCALHOST . Ich kann Nachrichten mit TCP, http-Protokollen konsumieren. Code; public static void main(String[] args) throws JMSException { PropertyUtils.loadPropertyFile(); ....
12 Feb. 2021 im 17:08
Kann ActiveMQ eine Warteschlange im Arbeitsspeicher anstelle der Festplatte hinzufügen, und wenn ja, wie ist die Konfiguration dafür? Dies ist die Datei my activemq.xml und die ActiveMQ-Version ist 5.14.3. Ich muss wissen, was genau ich hier oder in anderen Konfigurationsdateien konfigurieren soll, ....
11 Feb. 2021 im 14:21
Wie viele Warteschlangen können in ActiveMQ erstellt werden? Gibt es Einschränkungen in ActiveMQ 5.14? Ich habe eine Java-Anwendung, die 1 Warteschlange pro Kunde erstellen muss. Meine Sorge ist, was sich auswirkt, wenn ich die Warteschlange mit mehr als 1.000 Warteschlangen erstelle.....
10 Feb. 2021 im 15:24
Ich verwende die zusammengesetzte Warteschlange von ActiveMQ vor physischen Warteschlangen, da die Berechtigungen auf Hersteller- und Verbraucherseite unterschiedlich festgelegt werden können. Und das funktioniert wie geplant. Ich möchte auch eine zusammengesetzte Warteschlange vor Themen verwenden....
6 Feb. 2021 im 14:03
Wir migrieren von Mule 3 zu Mule 4 und in einer unserer Funktionen müssen wir Nachrichten zu einem Thema veröffentlichen und nachgeschaltet verbraucht eine andere Mule-Komponente aus der Warteschlange, die mit dem Thema verbunden ist. Hier gibt es nichts Besonderes. Um sicherzustellen, dass wir ....
20 Dez. 2020 im 02:16
Wir haben den ActiveMQ-Broker der Version 5.16.0 mit einzelnen Instanzen in der Produktion verwendet. Jetzt planen wir die Verwendung eines Clusters von AMQ-Brokern für die HA- und Lastverteilung mit konsistenter Nachrichtendaten. Derzeit verwenden wir nur eine Warteschlange Das war der einfachste W....
11 Okt. 2020 im 12:15
Ich versuche, einen geplanten Job in ActiveMQ zu löschen, und bisher kein Glück. Der Zeitplan wird zusammen mit der Nachricht entweder mithilfe von NMS-API oder Amqpnetlite (außer openwire lib, da diese nicht aktualisiert wird und nicht für netstandard / netcore verwendet werden kann) Beispielcode z....
10 Sept. 2020 im 14:21
Ich arbeite an einer Anwendung (Spring Boot-Anwendung), die das zur Laufzeit von einer anderen Anwendung erstellte Thema abhören soll. Wie kann ich wissen, dass zur Laufzeit ein neues Thema auf dem Activemq Broker erstellt wird? Und wie kann ich anfangen, das neu erstellte Thema zur Laufzeit anzuhö....
8 Sept. 2020 im 15:06
Beim Starten des Spring-Starts bleibt die Anwendung hängen und SpringApplication.run wird nicht zurückgegeben. @Configuration @ComponentScan @EnableAutoConfiguration public class AccountServiceApplication extends SpringBootServletInitializer { public static void main(String[] args) { Co....
16 Mai 2019 im 03:50
Ich versuche, Spring JMS und ActiveMQ zu verwenden, um eine große Anzahl von Nachrichten zu verarbeiten. Der Kontext des Problems ist folgender: Jeder Kunde erstellt eine Reihe von Nachrichten, die der Warteschlange hinzugefügt werden. Die Nachrichten werden der Warteschlange mit der Kunden-ID als P....
10 Apr. 2019 im 23:15
Ich bin kein ActiveMQ-Experte, aber ich habe versucht, im Internet nach ähnlichen Problemen zu suchen, und bin immer noch ziemlich verwirrt. Ich habe folgendes Problem. Ausführen einer Webanwendung in Tomcat 8.x, Java 8, Spring Framework 4.3.18. Meine Webanwendung sendet und empfängt Nachrichten mit....
11 Jän. 2019 im 11:56
Ich habe eine App, die ActiveMQ verwendet, und normalerweise teste ich sie mithilfe der Web-Benutzeroberfläche von AMQ, um Nachrichten an Warteschlangen zu senden, aus denen meine Software verbraucht. Ich wollte dies halbautomatisieren und hoffte, dass die AMQ-Befehlszeile die Möglichkeit hat, eine ....
14 Nov. 2018 im 23:27
Ich habe folgenden Code zum Veröffentlichen von Nachrichten in activeMQ und zum Lesen der Antwort über den Austausch. Aber der Code scheint sofort zurückzukehren und nicht auf die Antwort zu warten. Könnten Sie bitte darauf hinweisen, was mit dem folgenden Scala-Code nicht stimmt? def sendAndRecei....
26 Juni 2018 im 08:22