Tag: rabbitmq

RabbitMQ ist eine open-source-message-broker, die ursprünglich Implementierung des AMQP-Protokoll mit zusätzlichen messaging-Protokolle unterstützt, die über eine plug-in-Architektur. Dieser tag sollte verwendet werden, mit Fragen, die die RabbitMQ-server message broker Produkt oder Fragen bezüglich des Quellcodes und die Implementierung der RabbitMQ-Produkt. Eine bestimmte Protokoll-tag wie amqp oder mqtt können ebenfalls geeignet sein, sowie das Betriebssystem und die Programmiersprache, die verwendet wird.

RabbitMQ Exchange Type-Vergleich: Thema vs. Kopf

Anzahl der Antworten 1 Antworten
Wir bauen für Sie unser message-queue-system. Zwar werde über die RabbitMQ-exchange-Typen, die ich bemerkte, gibt es zwei mögliche Lösungen zur Umsetzung der multi-cast-Art der Weiterleitung von Nachrichten. Thema Exchange. Durch die Einrichtung ein Thema exchange-und eine routing-Schlüssel

Rabbit MQ nicht starten

Anzahl der Antworten 1 Antworten
Ich nach Abschluss der Installation von RabbitMQ mit dem folgenden RPM - http://www.rabbitmq.com/releases/rabbitmq-server/v2.7.1/rabbitmq-server-2.7.1-1.noarch.rpm installierte ich es so : $ wget \ http://www.rabbitmq.com/releases/rabbitmq-server/v2.7.1/rabbitmq-server-2.7.1-1.noarch.rpm $ rpm --nodeps -Uvh rabbitmq-server-2.7.1-1.noarch.rpm der Grund, warum ich verwendet --nodeps war, weil ich installiert

Ist es möglich, um sicherzustellen, dass eindeutige Nachrichten werden in einem rabbitmq Warteschlange?

Anzahl der Antworten 2 Antworten
Grundsätzlich meine Konsumenten werden Produzenten. Wir bekommen einen ersten Datensatz und es wird an die Warteschlange gesendet. Ein Verbraucher nimmt ein Element und Prozesse, die Sie von diesem Punkt aus gibt es 3 Möglichkeiten: Daten ist gut

Ist es angemessen, message queues, die für synchrone rpc-Aufrufe via ajax

Anzahl der Antworten 2 Antworten
Ich habe eine web-Anwendung, die verwendet das jquery autocomplete-plugin, das im wesentlichen sendet per ajax eine Anfrage mit text, der eingegeben wurde, in ein Textfeld auf unseren web-server, sobald der web-server empfängt diese Anfrage, es reichte dann

RabbitMQ auf EC2 Verbraucht Unmengen von CPU

Anzahl der Antworten 2 Antworten
Ich versuche, RabbitMQ mit Sellerie und Django geht auf eine EC2-Instanz zu tun, ein paar ziemlich grundlegende hintergrund-Verarbeitung. Ich bin mit rabbitmq-server 2.5.0 auf einem großen EC2-Instanz. Ich heruntergeladen und installiert die test-client nach der Anleitung hier

Unmarshaling In einem Interface{} und Anschließend Ausführen, Geben Sie Behauptung

Anzahl der Antworten 2 Antworten
Bekomme ich eine string durch ein rabbitmq-message-system. Vor dem senden, Benutze ich json.Marshal konvertieren, das Ergebnis zu string und senden durch rabbitmq. Den Strukturen, die ich konvertieren und senden kann: (die Namen geändert und die Größe der

Wie funktioniert RabbitMQ tatsächlich speichern die Nachricht physikalisch?

Anzahl der Antworten 1 Antworten
Möchte ich wissen, wie funktioniert RabbitMQ speichern die Nachrichten, die physikalisch an RAM und Festplatte? Ich weiß, dass RabbitMQ versucht die Nachrichten in Erinnerung (Aber ich weiß nicht, wie die Nachrichten in den Ram). Aber die Nachrichten

multi-threading basiert RabbitMQ Verbraucher

Anzahl der Antworten 2 Antworten
Wir haben ein windows-Dienst, das hören auf einzelne RabbitMQ Warteschlange und verarbeiten der Nachricht. Wir möchten Sie herzlich derselben windows-Dienste, so dass Sie hören können mehrere Warteschlangen von RabbitMQ und verarbeiten der Nachricht. Nicht sicher, ob das

Wie zu deaktivieren, RabbitMQ Standard-tcp listening port (tcp - 5672

Anzahl der Antworten 3 Antworten
Ich so konfiguriert haben, dass die RabbitMQ rabbitmq.config - Datei mit der neuen port-Nummer, D. H. 5671 mit SSL. Nun möchte ich deaktivieren Sie die Standard-port-d.h. 5672. Config-Datei wie folgt :- [ {rabbit, [ {ssl_listeners, [5671]}, {ssl_options,

org.apache.camel.InvalidPayloadException: Kein Körper zur Verfügung des Typs error geworfen, während Jaxb unMarshalling Objekt

Anzahl der Antworten 2 Antworten
Sende ich JAXB-Objekt Rabbit MQ via Java. JAXBContext jaxbContext = JAXBContext.newInstance(MyDTO.class); Marshaller jaxbMarshaller = jaxbContext.createMarshaller(); //output pretty printed jaxbMarshaller.setProperty(Marshaller.JAXB_FRAGMENT, true); java.io.StringWriter sw = new StringWriter(); jaxbMarshaller.marshal(deliveryrequest, sw); ConnectionFactory factory = new ConnectionFactory() ; //TODO change the hardcoding

Fehler beim Erstellen des Cookie-Datei RabbitMQ in Windows

Anzahl der Antworten 2 Antworten
Ich versuche, führen Sie den folgenden Befehl rabbitmq-plugins.bat enable rabbitmq_management und sein gibt mir eine Fehlermeldung Fehler beim erstellen des cookie-Datei h:/. Ich bin mit windows 7, Erlang Version R16B01 und RabbitMQ-Server version 3.1.5 Ich bin mit

Keine Verbindung mit Spring AMQP / Rabbit MQ : org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect

Anzahl der Antworten 3 Antworten
Ich bin neu in Spring AMQP /Rabbit MQ. Bin mit einem Spring AMQP /Rabbit MQ in meinem Projekt. Ich bin mit folgenden Fehler nach der Ausführung einer tomcat: org.springframework.amqp.Kaninchen.listener.SimpleMessageListenerContainer - Verbraucher ausnahmeereignis, kann die Verarbeitung neu starten,

So senden Sie ein JSON-Nutzlast zu RabbitMQ mit dem web-plugin?

Anzahl der Antworten 2 Antworten
Ich habe eine RabbitMQ 3.4.2 Beispiel mit einem web-management-plugin installiert. Wenn ich push-to-die Nachricht {'operationId': 194} an die Warteschlange über Python ' s kombu queue-Paket, wird die Nachricht Lesen, die am anderen Ende als ein Wörterbuch. Allerdings,

Wie aufzuhören Nachricht von selektiven queue RabbitMQ

Anzahl der Antworten 1 Antworten
QueueingConsumer consumer = new QueueingConsumer(channel); System.out.println(consumer.getConsumerTag()); channel.basicConsume("queue1", consumer); channel.basicConsume("queue3", consumer); Ist es möglich, aufzuhören die Nachrichten aus der Warteschlange "queue3" allein dynamisch? InformationsquelleAutor user1182253 | 2014-04-28

Weg zu brechen, dass eine Verbindung von rabbitmq

Anzahl der Antworten 2 Antworten
Ich habe eine Anwendung, die einige bugs hat. Für einige Grund 2 die Verbraucher werden erstellt, wenn nur eine da sein sollte - und einer von Ihnen ist nicht geprüft für Nachrichten mehr. Kann ich erkennen, dass

amqp-oder xmpp-für real-time online-Spiele

Anzahl der Antworten 4 Antworten
Welche diese Technologie-suite für Multi-user-online-Spiel-Projekt.. Anforderungen an ein Projekt: 1. In der Lage zu handhaben 2k-5k user zu einem bestimmten Zeitpunkt. 2. client-Bibliothek für iphone und android (native, kein javascript). 3. client-Bibliothek für Microsoft Windows (die wichtigsten),

Ist VirtualHost ein gutes Muster in RabbitMQ?

Anzahl der Antworten 1 Antworten
Ich habe 100 Kunden. Jeder Kunde hat eine eindeutige Benutzername, Passwort und die zwei Kanäle (Benutzer können keine Verbindung zu anderen Kanälen, abgesehen von Ihrer eigenen). Sollte ich VirtualHost-Eintrag für jeden Benutzer? Wie schreibt man richtige Benutzer

Wie load balancer arbeitet in RabbitMQ

Anzahl der Antworten 1 Antworten
Ich bin neu RabbitMQ, so bitte ich um Entschuldigung für die trivialen Fragen: 1) Im Falle von clustering in RabbitMQ, wenn ein Knoten fehlschlägt, laden Sie die Umschalttaste auf einen anderen Knoten (ohne dass die anderen Knoten).

RabbitMQ-Verbindung über Nginx

Anzahl der Antworten 4 Antworten
Ich bin versucht, setup-rabbitmq es von extern erreichbar ist (nicht localhost) durch nginx. nginx-rabbitmq.conf: server { listen 5672; server_name x.x.x.x; location /{ proxy_pass http://localhost:55672/; } } rabbitmq.conf: [ {rabbit, [ {tcp_listeners, [{"127.0.0.1", 55672}]} ] } ] Standardmäßig

Wie lade ich das testen einer RabbitMQ-server (Entweder mit JMeter, python oder anderen Tools..)?

Anzahl der Antworten 2 Antworten
Ich habe Zugang zu einem RabbitMQ-server zu tun, eine Last test auf Sie zu. Ich bin ganz neu auf Server und AMQ Protokoll. Ich habe schon online recherchieren, um zu sehen, was sind einige verschiedene Methoden. Bisher

Publish/Subscribe-Muster mit RabbitMQ in .NET

Anzahl der Antworten 3 Antworten
Habe ich gebaut, dieses Beispiel: Erste Schritte Mit RabbitMQ in .net, aber aus 2 Programmen: eine-Verlag one-Abonnenten Ich bin mit BasicPublish zu veröffentlichen und zu BasicAck zu hören, wie im Beispiel. Wenn ich einen Verleger und mehrere

RabbitMQ konnte nicht initialisiert werden erlang-Verteilung

Anzahl der Antworten 2 Antworten
Habe ich installiert RabbidMQ aber wenn ich versuche, mit rabbitmqctl status im cmd habe ich nächste Ergebnis : D:\RabbitMQ\rabbitmq_server-3.6.2\sbin>rabbitmqctl status Error: Failed to initialize erlang distribution: {{shutdown, {failed_to_start_child, net_kernel, {'EXIT',nodistribution}}}, {child,undefined, net_sup_dynamic, {erl_distribution, start_link, [['rabbitmq-cli-70', shortnames]]}, permanent,1000,supervisor,

Zugriff verweigert für Benutzer rabbitmq & Sellerie

Anzahl der Antworten 4 Antworten
Ich erstelle vhost: rabbitmqctl add_vhost test Dann Benutzer: rabbitmqctl add_user user 123456 Dann nehme ich die Berechtigungen, die dem Benutzer: rabbitmqctl set_permissions -p test user "test" "test" "test" Ich verwende Sellerie, in tasks.py: app = Celery('tasks', broker='amqp://user:123456@localhost/test',

RabbitMQ— selektiv abrufen von Nachrichten aus einer Warteschlange

Anzahl der Antworten 2 Antworten
Ich bin neu RabbitMQ und Frage mich, für einen guten Ansatz, um dieses problem bin ich grübelte über. Ich möchte einen Dienst erstellen, der bekennt sich zu einer queue und zieht nur Nachrichten, die eine bestimmte Kriterien

Wie funktioniert rabbitmq heartbeat-Arbeit

Anzahl der Antworten 1 Antworten
Die native rabbitmq-client für java ermöglicht das setup von heartbeat auf Verbindungs-Einstellungen, wie zum Beispiel diese: import com.rabbitmq.client.ConnectionFactory; ... ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setAutomaticRecoveryEnabled(true); connectionFactory.setHost("some://host"); connectionFactory.setConnectionTimeout(5000); connectionFactory.setRequestedHeartbeat(5); //keeps an idle connection alive Was ist das rabbitmq-client

Sellerie Speicher nicht freigegeben werden

Anzahl der Antworten 4 Antworten
Sieht es aus wie Sellerie Speicher nicht freigegeben werden, nachdem Aufgabe beendet. Jedes mal, wenn eine Aufgabe abgeschlossen ist, es wäre 5m-10m-memory-Leck. So mit tausenden von Aufgaben, bald wird es zu verwenden, bis alle Speicher. BROKER_URL =

Ausnahmen in rabbitmq mit spring boot

Anzahl der Antworten 3 Antworten
Ich bin immer der folgenden Ausnahme wiederholt, wenn ich mein spring-boot-Anwendung mit rabbitmq. Der gesamte Durchfluss ist in Ordnung, die sogar von den unten genannten Ausnahmen. hat es zu tun mit der auto-delete durch ? 08 Jul

spring boot rabbitmq MappingJackson2MessageConverter benutzerdefinierten Objekts der Konvertierung

Anzahl der Antworten 2 Antworten
Ich bin versucht, zu erstellen eine einfache spring-boot-Anwendung mit spring-boot, die "produzieren" - Nachrichten an einen rabbitmq exchange/queue und ein weiteres Beispiel spring-boot-app, die sich "verbrauchen" diese Nachrichten. Also ich habe zwei apps (oder microservices, wenn Sie

RabbitMQ: Was ist der Standard-x-message-ttl-Wert

Anzahl der Antworten 1 Antworten
Konnte ich nicht finden im RabbitMQ-Dokumentation die Standard-x-message-ttl-Wert kommt mit der installation. Ich wissen, wie es auf einen gewünschten Wert, aber ich bin neugierig zu wissen, den default-Wert. InformationsquelleAutor Martin Chen | 2014-07-25

Schlösser und batch-Holen von Nachrichten mit RabbitMq

Anzahl der Antworten 3 Antworten
Ich versuche, RabbitMq in einer eher unkonventionellen Weg (obwohl an dieser Stelle kann ich wählen Sie eine andere message-queue-Implementierung, wenn nötig). Anstatt Kaninchen push-Nachrichten an meine Verbraucher, der Verbraucher eine Verbindung zu einem queue und holt einen

Sellerie - errno 111 connection refused

Anzahl der Antworten 2 Antworten
Mein Sellerie Aufgaben aufhört, ausgeführt zwischen. Meine rabbitmq Haltestellen dazwischen und dann muss ich manuell neu starten. Beim letzten mal(15-16 Stunden zurück), ähnliches problem aufgetreten ist, habe ich Folgendes (manuell), und es begann wieder zu arbeiten. Ich

Einstellung einer langen timeout für RabbitMQ ack-Nachricht

Anzahl der Antworten 1 Antworten
Ich Frage mich, ob dies möglich ist. Ich möchten, ziehen Sie eine Aufgabe aus einer Warteschlange und haben einige arbeiten, die potenziell überall von 3 Sekunden oder länger (möglicherweise) Minuten, bevor ein ack gesendet wird, zurück zum

Problem in der Verbindung mit Rabbit MQ

Anzahl der Antworten 3 Antworten
code import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; public class Send { private final static String QUEUE_NAME = "test"; public static void main(String argv) throws java.io.IOException { try { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); Connection connection =

Wie zu verwenden rabbitmqctl zu verbinden, um die rabbitmqserver in den docker-container?

Anzahl der Antworten 5 Antworten
Ich verwendet habe, docker zu Beginn meines rabbitmqserver. Wie kann ich rabbitmqctl zu verbinden, um die rabbitmqserver in den docker-container? Port 5672 wurde ausgesetzt und map 5672-port von meinem host. Aber ich bekomme immer noch folgende Fehlermeldung:

Verbindliche externe IP-Adresse zu Rabbit MQ server

Anzahl der Antworten 2 Antworten
Habe ich Eine box und es hat ein Verbraucher, der es hört, die auf ein Kaninchen MQ server Ich habe Feld B, das veröffentlichen einer Nachricht an den listener So lange, wie all dies auf der box

Automatisch verbindet, RabbitMQ-Kanäle

Anzahl der Antworten 4 Antworten
Fand ich dieses Kleinod: In der Ausfall der Verbindung, der client zum herstellen einer neuen Verbindung zum broker. Alle Kanäle geöffnet, die auf der vorherigen Verbindung wird automatisch geschlossen, und diese wird wieder der öffnung zu. So,

Wie implementieren single-consumer-multi-queue-Modell für rabbitMQ

Anzahl der Antworten 2 Antworten
Ich gefunden habe, dieses Bild ist sehr ähnlich wie meine bussiness-Modell. Ich brauche split-message, um einige der Warteschlange. für einige schwere Arbeit. Ich kann hinzufügen, mehr worker-thread für Sie. Aber für einige nicht viel schwere Arbeit. Ich

RabbitMQ: handshake-Fehler beim verwenden von SSL-Zertifikaten

Anzahl der Antworten 3 Antworten
Ich versuche, verwenden Sie SSL-Zertifikate mit RabbitMQ aber ich bekomme den handshake Fehler mit dem Makler. Zertifikate, die ich generiert haben, funktionieren gut bei der Verwendung der openssl 's_client' und 's_server" - Befehle in separaten terminal-Fenster und

Microservices Warum Die Verwendung Von RabbitMQ?

Anzahl der Antworten 2 Antworten
Ich habe nicht gefunden, einen vorhandenen Beitrag gefragt, aber entschuldige mich, wenn ich es verpasst. Ich versuche, meinen Kopf Runde microservices und haben über Artikel, in denen RabbitMQ verwendet. Ich bin verwirrt, warum RabbitMQ ist erforderlich. Ist

HelloWorld-Beispiel zum senden eines Objekts über RabbitMQ über EasyNetQ zwischen zwei verschiedenen Anwendungen

Anzahl der Antworten 3 Antworten
Hallo, ich bin versucht, senden Sie einen einfachen Gegenstand, wie durch RabbitMQ über EasyNetQ. Habe ich Probleme, zu Deserialisieren das Objekt auf der Abo-Seite. Jemand in der Lage mir zu zeigen, ein Beispiel, wie dies funktioniert. Halten

Spring-RabbitMQ - mit manueller Kanal-Bestätigung auf einen Dienst mit @RabbitListener Konfiguration

Anzahl der Antworten 3 Antworten
Wie zu erkennen die Nachrichten manuell, ohne die Verwendung der automatischen Anerkennung. Gibt es eine Möglichkeit, verwenden Sie diese zusammen mit der @RabbitListener und @EnableRabbit - Stil der Konfiguration. Der größte Teil der Dokumentation erzählt uns SimpleMessageListenerContainer

Senden Binärdatei durch RabbitMQ

Anzahl der Antworten 3 Antworten
Bin ich spec ' Ing eine design jetzt verwendet RabbitMQ als message queue. Die Botschaft gehen, um eine JSON-Körper, und für eine Nachricht im besonderen möchte ich hinzufügen, eine kleine binäre Datei. Was ich wissen möchte ist,

RabbitMQ: Wie requeue-Nachricht mit Zähler

Anzahl der Antworten 2 Antworten
Gibt es eine Möglichkeit zu zählen wie viel Zeit ein Auftrag requeued (über Ablehnung oder Nak), ohne manuell requeu den job? Ich muss versuchen einen job für 'n" - Zeit und dann legen Sie es nach -

RabbitMQ nicht starten

Anzahl der Antworten 10 Antworten
Den RabbitMQ-windows-Dienst wird nicht gestartet: C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.0.4\sbin>rabbitmq-service.bat start C:\Program Files (x86)\erl5.10.1\erts-5.10.1\bin\erlsrv: Failed to start service RabbitMQ. Error: The process terminated unexpectedly. Ich kann laufen, rabbitmq-server.bat ohne Probleme. Werden keine log-Einträge aus %appdata%\RabbitMQ\log\ - Verzeichnis, wenn

Wie einrichten autoskalierender RabbitMQ-Cluster, AWS

Anzahl der Antworten 2 Antworten
Ich versuche, Weg von SQS zu RabbitMQ für den messaging-Dienst. Ich bin auf der Suche nach Aufbau eine stabile, hohe Verfügbarkeit queuing-Dienst. Jetzt werde ich mit cluster. Aktuellen Implementierung , Ich habe drei EC2-Maschinen mit RabbitMQ mit

Die Installation von rabbitmq-server auf RHEL

Anzahl der Antworten 2 Antworten
Wenn Sie versuchen zu installieren rabbitmq-server auf dem RHEL: [ec2-user@ip-172-31-34-1XX ~]$ sudo rpm -i rabbitmq-server-3.3.5-1.noarch.rpm error: Failed dependencies: erlang >= R13B-03 is needed by rabbitmq-server-3.3.5-1.noarch [ec2-user@ip-172-31-34-1XX ~]$ rpm -i rabbitmq-server-3.3.5-1.noarch.rpm error: Failed dependencies: erlang >= R13B-03 is

MessageConversionException: Fehler beim konvertieren der Inhalt der Nachricht

Anzahl der Antworten 2 Antworten
Ich habe eine SpringBoot Anwendung macht die Verwendung von Spring AMQP. Im moment bin ich der Umsetzung der Empfängerseite mit JavaConfig Klassen unter der Leitung der offizielle Frühling docs Beispiele. Aber, ich erhalte eine MessageConversionException und die

Spring AMQP RabbitMQ wie man zwei parallele Verbraucher nicht greifen gleiche Aufgabe in der gleichen Zeit?

Anzahl der Antworten 3 Antworten
Habe ich zwei Systeme integriert sind, mit RabbitMQ. Hintergrund Client-senden Sie multiple-request-Nachrichten von Spring-AMQP outbound-Gateway zu RabbitMQExchange, die rabbitmq-DirectExchange verwenden round-robin - Versand dieser Nachrichten an Mehrere Arbeitnehmer(die Arbeiter sind unabhängige, die sich auf verschiedenen desktops die

RabbitMQ Vs. MSMQ Microsoft Azure Cloud-Plattform

Anzahl der Antworten 1 Antworten
Ich würde gerne ein Message-Oriented-Middleware (MOM) mit Microsoft Azure cloud-Plattform. Ich habe ein wenig den Vergleich zwischen dem RabbitMQ und MSMQ. Die erste scheint besser zu sein für meinen Fall. Es ist einfacher, mit zu arbeiten und

rabbitMQ Gast-login fehlgeschlagen

Anzahl der Antworten 2 Antworten
Habe ich setted rabbitMQ und seine Verwaltung plubin in windows, Fand ich rabbitmq.config-Datei mit "BEISPIEL-DATEI" den Pfad eingeben, in der " ...AppData\Roaming\RabbitMQ " und " C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.3.1\etc " Füge ich die Zeile {loopback_users, } in