Tag: activemq

Apache ActiveMQ ist ein open-source (Apache 2.0 Lizenz) – message-broker, die vollständig implementiert den Java Message Service 1.1 (JMS). Es bietet eine „Enterprise-Features“ wie clustering, multiple message stores, und die Möglichkeit zur Nutzung einer Datenbank als JMS-provider neben VM -, cache-und journal-Persistenz.

Apache Camel throws java.lang.NoSuchMethodError: org.apache.camel.util.ObjectHelper.notNull

Anzahl der Antworten 2 Antworten
Habe ich ein groovy-Skript, dass ich versuche, zu gehen; es ist die Aufgabe Lesen einer message queue, und dann erneut in die Warteschlange der Nachrichten in eine neue MQs setzen wir live. Hier der code: @Grab(group='org.apache.camel', module='camel-core',

Verteilt mit Camel, ActiveMQ

Anzahl der Antworten 2 Antworten
Ich bin in den Prozess des Lernens, ActiveMQ und Camel, mit dem Ziel zu erstellen, einen kleinen Prototyp-system, das funktioniert ungefähr so: (Quelle: paulstovell.com) (big) Bei einer Bestellung wird in der Orders-system, eine Nachricht wird verschickt an

Unregelmäßig javax.jms.JMSException: Peer entsorgt

Anzahl der Antworten 2 Antworten
Ich habe ein unberechenbares problem mit Java JMS. Für Momente funktioniert einwandfrei, wirft aber folgende Ausnahme erratisch und schneiden Sie die Ausführung. Es ist wichtig zu beachten, dass dies geschieht, ohne dass die broker. javax.jms.JMSException: Peer (vm://test#1)

ActiveMQ Drosselung der Verbraucher

Anzahl der Antworten 3 Antworten
möchte ich eine Drosselung für einen Verbraucher, der einige queue des activeMQ, in hornetq (von jboss, das ist es tun, mit Anmerkungen über die definition des mdb-Consumer). Ich finde nichts ähnliches in der Dokumentation des activemq, die

Wie man alle Nachrichten in die Warteschlange eingereiht in ActiveMQ?

Anzahl der Antworten 2 Antworten
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

Was ist der Standard-port für den JMX-in ActiveMQ?

Anzahl der Antworten 1 Antworten
Ich bin mit ActiveMQ 5.3.2 und 5.6.0. Im ActiveMQ 5.3.2 Standardeinstellungen für die JMX ist SUNJMX="-Dcom.sun.management.jmxremote" In der ActiveMQ-5.6.0, die Standard-Einstellungen für die JMX ist ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote" Damit, diese Einstellungen haben keine port-definition. Könnten Sie mir sagen,

Verfallen-Nachrichten auf der ActiveMQ, wenn es keine Abonnenten

Anzahl der Antworten 2 Antworten
Beim hinzufügen von Nachrichten an eine queue, in die eine ActiveMQ-broker, wo es keine Abonnenten, die Warteschlange füllt und schließlich der Produzent-thread hängt, nicht veröffentlichen kann mehr Nachrichten. In einem Versuch, das problem zu beheben ich ein

Wie setzen Message-ID in der Activemq-jms-Queue?

Anzahl der Antworten 2 Antworten
Heruntergeladen habe ich activemq version 5.8.0 und schrieb das Beispiel-Programm zum erstellen von Warteschlangen. Ich schickte eine Probe-Nachricht an eine Warteschlange erfolgreich. Danach habe ich versucht, die message-ID der bestimmten Nachricht. Die message-ID kann verwendet werden, um

Mit JMS oder ThreadPool senden von E-Mail-Nachrichten

Anzahl der Antworten 4 Antworten
Ich gerne wissen: Habe ich ein Szenario. Wenn ein Benutzer fügt ein Produkt zum system (ich bin der Entwicklung), gibt es einen listener, der sendet eine Benachrichtigung an den Benutzer, die client-Basis die Benachrichtigung eines neuen Produkts

Es konnte keine Verbindung zur RMI-Registrierung

Anzahl der Antworten 2 Antworten
Ich bin mit activemq-5.9 auf Ubuntu 12.04 und es wäre fair zu sagen, dass ich neu bin und active MQ. Vermute ich, dass ich bin queueing-Datensätze und nicht de-queueing Sie, ich bin auf der Suche in verwenden

Die Verwendung von Transaktionen mit JMS (ActiveMQ)

Anzahl der Antworten 1 Antworten
In unserem backend gibt es verschiedene Dienste, die das senden und empfangen von Nachrichten über JMS mit Apache ActiveMQ. Jeder Dienst hat einen single-session auf den ActiveMQ-broker. Wir wollen nun den folgenden (pseudo-code): Service s1: Message m

ActiveMQ JMS vs

Anzahl der Antworten 1 Antworten
Ich versuche zu verstehen JMS. Was ist der Unterschied zwischen ActiveMQ-und JMS - pool können die Daten von NICHT ActiveMQ mit ActiveMQ-plugin im Frühjahr? Dank Im Voraus Sie waren in der Lage, Ihr problem zu lösen? yaa....accpeted

Asynchrone senden einer Warteschlange mit Spring Jms-Problem

Anzahl der Antworten 1 Antworten
Ich eine Anforderung haben, wenn ich schreiben müssen, das die asynchron zu einer Warteschlange in der activemq. Ich bin mit Spring Jms, es zu tun. Dies ist die Verdrahtung in meiner Quelle Kontext-Datei <bean id="amqProducerConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property

Activemq - Überschritten die maximale Anzahl der zulässigen client-verbindungen

Anzahl der Antworten 2 Antworten
Meine acitvemq print server immer folgenden Fehler : 2014-07-12 16:14:27,820 | ERROR | Could not accept connection : org.apache.activemq.transport.tcp.ExceededMaximumConnectionsException: Exceeded the maximum number of allowed client connections. See the 'maximumConnections' property on the TCP transport configuration URI

ActiveMQ broker nicht ab

Anzahl der Antworten 4 Antworten
Ich versuche zu starten, die eine ActiveMQ-broker, momentan habe ich JDK 1.8.0_31 und ActiveMQ-5.11.1 installiert. Wenn ich activemq aus dem bin-Ordner in meinem ActiveMQ-installation bekomme ich folgende Meldung: Java Runtime: Oracle Corporation 1.8.0_31 C:\Program Files\Java\jdk1.8.0_31\jre Heap sizes:

Wie Installieren Sie den ActiveMQ-server in MAC OS-system?

Anzahl der Antworten 6 Antworten
Wie kann ich der Installation von ActiveMQ-Server in MAC OS X? Gibt es trotzdem, um seine installation source für MAC OS? Hier sind einige der Quelldateien für die installation, nicht aber für MAC OS. http://activemq.apache.org/activemq-5144-release.html Hier ist

So schließen Sie einen ActiveMQ-Produzent zu einem OpenMQ JMS-broker

Anzahl der Antworten 2 Antworten
Ich versuche zum senden von text-Nachrichten von einem swing heavy-client (Apache ActiveMQ-Bibliothek) zu einer Instanz des glassfish-server scheint das zu verwenden, OpenMQ als Standard-JMS-provider. Unter dem Quell-basic-code, den ich verwende für meine Kunden : try { ActiveMQConnectionFactory

Integration der vorhandenen tomcat-server mit Active MQ?

Anzahl der Antworten 2 Antworten
Ich bin mit tomcat als webserver. Planen der Verwendung von active mq für messaging Zweck. Gerade angefangen zu lernen über jms und activeMQ. Gone thru https://activemq.apache.org/getting-started.html. Was ich habe ist active mq kommt mit seiner eigenen web

Active MQ geben OutOfMemory-Fehler

Anzahl der Antworten 1 Antworten
Laufen wir activeMQ5.6 auf tomcat 6.0.35 als embedded-broker mit message delivery option legen Sie als PERSISTENT. Wir sind immer OutOfMemory-problem an einem der consumer-Seite. Der Verbraucher wird langsam wie sein tun zeitraubende Aufgabe. Wir verwendet, um die

Wiederholt melden : Warnen-Transport-Verbindung zu tcp:<ip> failed: java.net.SocketException: Connection reset

Anzahl der Antworten 1 Antworten
Ich bin mit ActiveMQ 5.9.0 Freigabe auf meinem lokalen Rechner für dev-Zwecke (Windows 7). Ich bin mit AMQP als das Protokoll und die Apache qpid als client zu verbrauchen, Nachrichten (publish-subscribe) von activeMQ-broker (AMQP 1.0-Protokoll). Zwar habe

Warum ist die Meldung wieder kommen zu onMessage () - Funktion?

Anzahl der Antworten 4 Antworten
Ich bin mit ActiveMQ um die Nachricht zu senden. So, wenn ich eine Nachricht gesendet, kommt die Meldung zu Meldung. Auf erfolgreiche insertion wird anerkannt. Aber ich habe code nach Bestätigung, die werfen kann NullPointerException. So zu

ActiveMQ löscht nie kahadb .log-Dateien; keine ausstehenden Nachrichten, die sichtbar durch die JSP-Schnittstelle, zu erkennen, wie Täter?

Anzahl der Antworten 2 Antworten
wir haben ActiveMQ 5.7.0 vorhanden läuft auf CentOS. Rund fünfzig Java-Programme schreiben zu konsumieren und Warteschlangen, etwa die Hälfte von den localhost und den rest verteilt über die remote-clients, die meisten mit der ein Verbraucher pro Prozess,

Was ist die richtige Maven-Abhängigkeiten zu nutzen Spring, JMS und ActiveMQ?

Anzahl der Antworten 2 Antworten
Dies ist ein Recht häufiges problem und ich habe viele Lösungen, die funktionieren nicht bei mir auf dem web. Ich sage: <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>3.0.7.RELEASE</version> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.5.0</version> </dependency> Jetty-plug-in <plugin> <groupId>org.mortbay.jetty</groupId> <artifactId>jetty-maven-plugin</artifactId> </plugin> Aber

Wie zum senden von FEHLERMELDUNG, STOMP clients mit Spring WebSocket?

Anzahl der Antworten 1 Antworten
Ich bin mit Spring STOMP über WebSocket-Implementierung mit einer full-featured ActiveMQ broker. Wenn Benutzer SUBSCRIBE zu einem Thema, es gibt einige Berechtigungen Logik, die Sie durchgehen müssen, bevor Sie erfolgreich angemeldet. Ich bin mit einem ChannelInterceptor, um

Wie Sie wissen, das ActivemQ-version?

Anzahl der Antworten 1 Antworten
Kann einer mir helfen, in diesem. Wie kann ich wissen, welche version von Apache ActiveMQ ist auf meinem system installiert Ich will wissen, von meinem Apache ActiveMQ-Konsole, welche version von Apache ActiveMQ ist auf meinem system installiert.

Kann der Inhalt einer AMQ Thema betrachtet werden, irgendwie?

Anzahl der Antworten 3 Antworten
Ich versuche, den Inhalt eines Themas mit activemq-admin. Dies ist, was ich versuche: ./activemq-admin browse --amqurl tcp://localhost:61616 my.topic Dies ist, was bekomme ich als Ausgabe: Java Runtime: Sun Microsystems Inc. 1.6.0_24 /usr/lib/jvm/java-6-sun-1.6.0.24/jre Heap sizes: current=62848k free=62190k max=932096k

Autoreconnect problem mit ActiveMQ und CachingConnectionFactory

Anzahl der Antworten 2 Antworten
Ich habe ein problem mit ActiveMQ und Feder CachingConnectionFactory. Ich werde diese wie diese: <!-- A connection to ActiveMQ --> <bean id="myConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="${jms.url}"/> <property name="userName" value="${jms.username}"/> <property name="password" value="${jms.password}"/> </bean> <!-- A cached connection

AMQP 0-9-1 vs 1-0

Anzahl der Antworten 1 Antworten
Ich bin auf der Suche für einen messaging-Dienst für ein neues Projekt, an der Schnittstelle einige C# - Anwendungen einige Java-Anwendungen. Ich wirklich wie RabbitMQ, weil es scheint, um beeindruckende Unterstützung für beide Technologien. Ich sehe in

Senden von Nachrichten an ActiveMQ über internet

Anzahl der Antworten 3 Antworten
Ich soll zur Implementierung von messaging über das internet. Aber nicht die IP Öffentlich noch. So möchte ich Euch bitten, alle hier über das senden von Nachrichten an ActiveMQ mittels JMS über das internet? Könnte Es getan

Spring boot - Freigabe eingebetteten JMS-broker mit separaten service

Anzahl der Antworten 0 Antworten
Habe ich zwei Dienste, die sollte mit jedem anderen kommunizieren, über ActiveMQ. Alles funktioniert schön, wenn ich den Empfänger und Absender in eine service-aber wenn ich es aufteilen, ich habe eine seltsame activemq Ausnahme. Dies ist die

org.apache.activemq.transport.InactivityIOException: kann Nicht senden, Kanal bereits fehlgeschlagen ist

Anzahl der Antworten 2 Antworten
Ich bin mit apache ' s activemq für queueing. Wir haben begonnen, um zu sehen, die folgende Ausnahme sehr oft beim schreiben Dinge, die für die Warteschlange: Caused by: org.apache.activemq.transport.InactivityIOException: Cannot send, channel has already failed: at

ActiveMQ: wie dequeue ältere Nachrichten?

Anzahl der Antworten 2 Antworten
Ich bin, zu lernen, wie zu verwenden ActiveMQ und nun stehen wir vor dem folgenden problem. Angenommen, ich habe ein Thema namens Thema.test auf ActiveMQ die zwei Abonnenten. In einem bestimmten moment habe ich nur einen von

ActiveMQ-Nachrichten werden nachgeliefert (PooledConnectionFactory misconfig vermuten)

Anzahl der Antworten 2 Antworten
Ich habe eine Applikation, die mit spring MessageListenerContainers zusammen mit ActiveMQ. Ich habe es konfiguriert, um zu verwenden PooledConnectionFactory, folgende activemq-Dokumentation. Mein Szenario ist wie folgt: Zwei java-app der Verbraucher (2 verschiedene Kater) aus einer Warteschlange Master-slave-activemq-Broker,

activemq, wie zu konfigurieren, um die Arbeit mit stomp in python

Anzahl der Antworten 3 Antworten
Habe ich activemq installiert und lokal ausgeführt werden, aber wenn ich das folgende Skript ausführen, erhalte ich eine Fehlermeldung: #!/usr/bin/env python import time import sys import stomp class MyListener(object): def on_error(self, headers, message): print 'received an error

Können Thema Nachrichten gemacht werden persistent in activemq?

Anzahl der Antworten 1 Antworten
Ich bin ganz neu JMS-und ESB. Ich bin mit activemq als JMS und Maultier als ESB. Wenn ich die Weiterleitung der Nachrichten von einer queue zu einer anderen mit jms-Konnektor-parameter "persistentDelivery" als "true" behält es die Nachrichten

Spring integration: Empfangen von JMS-Nachrichten via adapter zufällig ausfällt

Anzahl der Antworten 2 Antworten
Ich bin versucht zu schreiben-channel-adapter für JMS-queue ein. Ich möchte, um eine Nachricht zu senden, um JMS-Warteschlange und erhalten Sie an der Spring-Integration-Kanal. Wenn ich mit normal-JMS (mit ActiveMQ), alles funktioniert einwandfrei, also gehe ich davon aus

Spring JMS Message Listener Container

Anzahl der Antworten 3 Antworten
Ich bin neu bei JMS und ich arbeite an der Einrichtung ActiveMQ mit Tomcat 6 und Frühling. Ich habe die meisten der grundlegenden Dinge konfiguriert, aber ich bin ein bisschen verwirrt mit der Message Listener Container, die

kann ich festlegen, das activemq-admin-Konsole-url?

Anzahl der Antworten 1 Antworten
Activemq in der admin-Konsole als standard, Punkte auf 0.0.0.0:8161. Ich weiß, ich kann ändern Sie den port von 8161 im jetty.xml config-Datei. Ist es möglich, ändern Sie die URL, die von 0.0.0.0? InformationsquelleAutor user814005 | 2013-10-17

JMS-message-Größe

Anzahl der Antworten 3 Antworten
Zur Zeit arbeite ich an Bandbreite begrenzende Funktion (frag mich nicht warum, es ist nicht meine Entscheidung) zur Anwendung, die Verwendung von JMS (Spring framework, JMS und Active MQ nämlich), um das senden von Nachrichten mit einer

ActiveMQ und JMS : Grundlegende Schritte für Anfänger

Anzahl der Antworten 2 Antworten
Hallo alle, bitte geben Sie einige Grundlagen über die ActiveMQ mit JMS für Anfänger. Und Konfigurations-Schritte auch. Down-Wähler : Diese Frage wurde bereits vor vielen Jahren, ich weiß, das ist ein low-Qualität Frage, aber nicht verdient downvotes.

ActiveMQ Einfache Authentifizierungs-Plugin - user admin ist nicht berechtigt, zu erstellen: Thema://ActiveMQ.Advisory.Verbindung

Anzahl der Antworten 1 Antworten
Ich veränderte unsere ActiveMQ-Konfiguration zu verwenden ActiveMQ Einfache Authentifizierungs-Plugin mit einem Benutzer und Passwort, hat alle Rechte an den Makler <plugins> <simpleAuthenticationPlugin> <users> <authenticationUser username="admin" password="pass" groups="admins,publishers,consumers" /> </users> </simpleAuthenticationPlugin> <authorizationPlugin> <map> <authorizationMap> <authorizationEntries> <authorizationEntry queue=">" write="producers"

mehrere SLF4J-Bindungen Fehler mit activemq-all-5.6.0.jar

Anzahl der Antworten 2 Antworten
Wenn ich ein upgrade auf activemq-alle-5.6.0 Ich bekomme diese Fehlermeldung beim Start des Servers SLF4J: Class-path enthält mehrere SLF4J-Bindungen Habe ich nicht dieses Problem bei der Verwendung von activemq-alle-5.5.1 Überprüfung finde ich, dass es StaticLoggerBinder.class in beiden

JMS / ActiveMQ: wenn ein Objekt mit Objekten als Klasse Mitglieder

Anzahl der Antworten 2 Antworten
Ich bin mit ActiveMQ (mit Feder) für das senden von Nachrichten an entfernte OSGi-Container. Dies funktioniert sehr gut, aber es gibt ein Problem. Habe ich zwei Klassen, die Serializable implementieren. Eine Klasse ist die Klasse von der

SpringBoot + ActiveMQ - Wie man Vertrauenswürdige Pakete?

Anzahl der Antworten 5 Antworten
Ich bin Schaffung von zwei springboot server & client-Anwendungen die Kommunikation mit JMS, und alles ist in Ordnung, mit der Veröffentlichung 5.12.1 für activemq, aber sobald ich update auf die 5.12.3 version, ich bekomme die folgende Fehlermeldung

ActiveMQ Verbraucher Hängt

Anzahl der Antworten 3 Antworten
Habe ich ein activeMQ-broker, die ein SSL-transport. Ich habe über 10 Verbrauchern sind mit der broker. Ich bin mit dem Kamel zum konfigurieren der meine Routen. Jeder so oft, es hängt sich auf und wird nicht verbrauchen,

ActiveMQ-queue löschen von java

Anzahl der Antworten 5 Antworten
Wie könnte ich es löschen einer Warteschlange in activemq aus java-Programm? Gibt es so etwas wie session.delelteQueue()? Dank M. siehe stackoverflow.com/questions/3036932/... Mögliche Duplikate von ActiveMQ - Entfernen von Warteschlangen programmgesteuert InformationsquelleAutor user1615276 | 2012-08-21

Warum meine ActiveMQ nicht starten

Anzahl der Antworten 2 Antworten
Ive wurde auf der Suche sehr, und ich konnte nicht herausfinden, warum, mein java ist korrekt installiert. Und die Umgebung-Eigenschaft korrekt ist auch. Versucht zu installieren, das ActiveMQ in Windows 7 64bit. Dies ist der ActiveMQ-5.8.0. Also

Activemq wird nicht starten auf meinem Ubuntu-VM

Anzahl der Antworten 4 Antworten
Ich versuche zu laufen, activemq auf meinem ubuntu virtual machine aber immer in Probleme laufen bekommen, es zu starten. Ich habe versucht, den Download der Binär-und source, ohne Glück. Derzeit habe ich heruntergeladen die Quelle verwenden, führen

Wie bekomme ich alle Nachrichten vom ActiveMQ-broker?

Anzahl der Antworten 1 Antworten
So, ich habe eine ActiveMQ-broker und einigen Produzenten, bringt einige self-made-Objekte in den broker. Ich habe auch einige Verbraucher erhalten die Nachrichten(serialisierte Objekte) ohne problem. Aber ich möchte ein Werkzeug zu schaffen, das in Verbindung zu dem

Unable to start Active MQ auf Linux

Anzahl der Antworten 2 Antworten
Ich versuche ActiveMQ-server auf einem RaspberryPI Debian Squeeze box und alles scheint richtig installiert aber wenn ich versuche den Dienst zu starten, erhalte ich folgende... root@raspberrypi:/var/www/activemq/apache-activemq-5.7.0# bin/activemq INFO: Loading/etc/default/activemq' INFO: Mit java '/usr/jre1.7.0_07/bin/java' /usr/jre1.7.0_07/bin/java: 1: /usr/jre1.7.0_07/bin/java:ELF0 4°: