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.

Wie zu öffnen rabbitmq im browser mit docker-container?

Anzahl der Antworten 4 Antworten
Diese wurde wahrscheinlich schon gefragt, aber bisher kann ich keine ausführliche Erklärung zu allen, und es existierten Dokumentation... gut, als ob es geschrieben wurde, für eine Art, die auf psychische, die angeblich alles wissen... Gemäß dieser Handbuch,

RabbitMQ: Keiner der angegebenen Endpunkte waren erreichbar

Anzahl der Antworten 4 Antworten
Meine rabbitmq Anwendung ausgeführt wird, auf windows server 2012, nach dem Zufallsprinzip, die ich verwenden, um diese Fehler. Exception Type: RabbitMQ.Client.Exceptions.BrokerUnreachableException None of the specified endpoints were reachable at RabbitMQ.Client.ConnectionFactory.CreateConnection() at Program.Main(String args) Stream does not support

Spring-RabbitMQ-tutorial Ergebnisse in Connection Refused Fehler

Anzahl der Antworten 2 Antworten
Ich bin ein erfahrener Java-Programmierer und bin ausprobieren, Spring Rabbit MQ für die erste Zeit. Folgte ich dem messaging-rabbitMQ-tutorial genau mit Maven. http://spring.io/guides/gs/messaging-rabbitmq/ Läuft bei mir auf CentOS als ein Benutzer-Konto. Bei mir lief der Anwendung am

Service-Orientierte Architektur - AMQP oder HTTP

Anzahl der Antworten 2 Antworten
Ein wenig hintergrund. Sehr großen monolithischen Django-Anwendung. Alle Komponenten nutzen die gleiche Datenbank. Wir müssen gesonderte Leistungen für so können wir unabhängig upgrade werden einige Teile des Systems, ohne den rest. Verwenden wir RabbitMQ als broker Sellerie.

Rabbitmq - mehrfach Bindung ( routing keys ) zu einer einzigen Warteschlange

Anzahl der Antworten 1 Antworten
Brauche ich eine Referenz bitte um eine multiple-routing-Tasten gebunden Warteschlange. Sie sehen, dass ich erstellt eine Warteschlange gebunden, einmal mit channel.queuebind() und ein anderes mal mit noch einmal channel.queuebind() bis ich diese zwei Bindungen auf der gleichen

Wie kann ich Sie erstellen oder hinzufügen eines Benutzers zu rabbitmq?

Anzahl der Antworten 3 Antworten
Dies scheint eine Frage, die sollte leicht sein, googleable. Es ist nicht obwohl. Kann jemand helfen? Wie erstelle ich einen neuen Benutzer für rabbitmq? InformationsquelleAutor Tobias Gassmann | 2016-11-05

So ändern Sie Standard-port(15672) des RabbitMQ-Management-Plug-in?

Anzahl der Antworten 3 Antworten
Ich bin mit einem RabbitMQ-Management-Konsole auf einem Computer, auf dem port oberhalb von 10000-range sind gesperrt über die firewall. Kann ich den port ändern, so dass ich kann verwenden Sie eine der 9000 Reihe ports ? Bitte

rabbitmq Liste Warteschlangen auf allen vhosts

Anzahl der Antworten 2 Antworten
Ich habe rabbitmq mit ein paar virtual hosts gibt es nur wenige Warteschlangen auf jedem. Wie kann ich eine Liste aller Warteschlangen aus allen vhosts mit rabbitmqctl? Ich habe versucht: rabbitmqctl list_queues -p /* rabbitmqctl list_queues -p

Konvertieren von Nachricht von RabbitMQ in string/json

Anzahl der Antworten 1 Antworten
Ich bin derzeit kämpfen hart mit einem fairen einfaches problem. Ich möchte eine Nachricht erhalten, die von RabbitMQ und haben, umgewandelt in einen string (oder später ein json-Objekt). Aber alles was ich bekomme ist Byte. Den Nachricht

ACCESS_REFUSED - Login wurde verweigert mit Authentifizierungsmechanismus PLAIN

Anzahl der Antworten 2 Antworten
Habe ich installiert "erlang" und "rabbitmq" in meinen windows 7-Rechner. Aber wenn ich versuche diesen code auszuführen, erhalte ich Eine exception. package com.rabbitmq; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class SendMessage { private final static String

Wie selektives löschen von Nachrichten aus einem AMQP (RabbitMQ) - Warteschlange?

Anzahl der Antworten 4 Antworten
Ich würde gerne selektives löschen von Nachrichten aus einem AMQP-Warteschlange ohne auch Sie zu Lesen. Das Szenario ist wie folgt: Versenden Seite will expire Nachrichten des Typs X basiert auf einer Tatsache, dass neue Informationen vom Typ

Client kann keine Verbindung zu RabbitMQ-server auf localhost

Anzahl der Antworten 2 Antworten
Ich frisch installiert, RabbitMQ 3.1.3 auf ubuntu 12.04.2 LTS per apt-get, und versuchen zu starten, die Verbraucher auf den gleichen server, aber ich habe Verbindung problem: [PhpAmqpLib\Exception\AMQPRuntimeException] Error Connecting to server(113): No route to host Gibt es

Wie gelangen Sie zu den detaillierten log/info über rabbitmq-Verbindung handeln?

Anzahl der Antworten 1 Antworten
Habe ich ein python-Programm Verbindung zu einem rabbitmq-server. Wenn dieses Programm gestartet wird, es verbindet auch. Aber wenn rabbitmq-server neu gestartet, mein Programm kann keine neue Verbindung herstellen, und verlassen nur Fehler "Socket geschlossen"(produziert von kombu), die

Rabbitmq-cluster-setup im Kubernetes

Anzahl der Antworten 2 Antworten
Habe ich erfolgreich die setup-rabbitmq-cluster mit docker compose zu verstehen, die clustering-Konzept. Es funktionierte gut, unten ist docker compose-Datei: rabbit1: image: ipf-queue-node hostname: rabbit1 cap_add: - ALL - NET_ADMIN - SYS_ADMIN ports: - "5671:5671" - "5672:5672" -

Was ist der beste Weg, um zu überwachen, rabbitmq, um sicherzustellen, dass alles reibungslos läuft?

Anzahl der Antworten 4 Antworten
Viele Male habe ich bekommen: Eingefroren, laden geht auf 5.0. Kann nicht mit meiner box. -Funktioniert einfach nicht. Können Sie ein bisschen mehr Informationen? Ist der 'box' - hosting der nur Rabbit MQ server allein oder auch

Durchführung von Kaninchen-message-listener zu ausgefallen und keine ErrorHandler festgelegt wurde. Fehler beim aufrufen von Ziel-Methode mit dem argument type = [class [B],

Anzahl der Antworten 2 Antworten
Bin ich mit spring amqp rabbitmq und senden von Nachrichten mithilfe Message message = MessageBuilder .withBody(item.toString().getBytes()) .setReplyTo("importReply") .setCorrelationId(item.toString().getBytes()).build(); Meine message handler public class Foundation { public Message importExchange(Message exchange) { System.out.println("Command:" + exchange.getBody()); Message message = MessageBuilder

epmd Fehler für host myhost: Adresse (keine Verbindung zu host/port) unter windows 10

Anzahl der Antworten 6 Antworten
Ich versuche zu installieren rabbitmq. Die installation der beiden erlang ich.e OTP-18.1-Datei getan wurde successfulyl und auch rabbitmq-installation erfolgreich abgeschlossen. Aber wenn ich versuche zu verbinden, rabbitmq, bekomme ich die folgende Fehlermeldung: C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.5.6\sbin>rabbitmq-plugins.bat enable

wie zu stoppen rabbitmq-Server

Anzahl der Antworten 5 Antworten
Ich versuche zum starten einer Knoten-Anwendung und ich denke, rabbitmq ist in der Weise erhalten. Ähnlich zu diesem thread: "Knoten mit dem Namen "rabbit" bereits ausgeführt", aber auch "keine Verbindung zu Knoten "rabbit"" $ ps aux |

RabbitMQ server-Fehler

Anzahl der Antworten 3 Antworten
AKTUALISIERT Fehlermeldung Ich bin immer ein BOOT FEHLGESCHLAGEN-Fehler jedes mal, wenn ich versuche, starten Sie den rabbitmq-server. Weiß jemand wie ich dies beheben können? Ich habe die angehängte Fehlermeldung. Ich habe versucht ein paar verschiedene Dinge, einschließlich

Wie die Verbindung von pika zu rabbitMQ remote-server? (python, pika)

Anzahl der Antworten 2 Antworten
In meiner lokalen Maschine, die ich haben kann: connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) für beide Skripts (send.py und recv.py), um die Kommunikation herzustellen, was aber eine Kommunikation von 12.23.45.67 zu 132.45.23.14 ? Ich weiß, über all die Parameter, die

Lächerlich langsam gleichzeitige veröffentlichen/konsumieren rate mit RabbitMQ

Anzahl der Antworten 2 Antworten
Ich bin der Bewertung RabbitMQ und während der Allgemeine Eindruck (von AMQP als solche, und auch RabbitMQ) ist positiv, ich bin nicht sehr beeindruckt von dem Ergebnis. Versuche ich zu veröffentlichen und konsumieren von Nachrichten gleichzeitig und

Mit Spring Integration mit RabbitMQ

Anzahl der Antworten 1 Antworten
Ich bin in den Prozess der Entwicklung einer messaging-Schnittstelle für eine unserer Anwendungen. Die Anwendung ist ein Dienst, welcher ausgelegt ist, zu akzeptieren, einen "Job" machen einige Verarbeitung und das Ergebnis (in form einer Datei). Die Idee

Apache camel,RabbitMQ, wie zum senden von Nachrichten/Objekte

Anzahl der Antworten 2 Antworten
Ich hoffe, jemand kann etwas Hilfe in dieser Angelegenheit. Bin ich mit dem Kamel rabbitmq und für die Prüfung Zweck, die ich bin versucht zu senden eine Nachricht an die queue, die ich versuche, die Anzeige im

RabbitMQ Fehler: konnte keine Verbindung zum Knoten : nodedown

Anzahl der Antworten 2 Antworten
Ich versuche zu tun, clustering mit zwei Rhel-Instanzen. Ich bin in der Lage zu pingen sich gegenseitig und selbst, wenn ich versuche, verwenden Sie den Befehl empd -names ich es zu bekommen ist und läuft auf 4369.Wenn

Verbindung im RabbitMQ-server auto verloren, nach 600s

Anzahl der Antworten 2 Antworten
Ich bin mit rabbitMQ server mit amq. Ich habe ein schwieriges problem. Nach dem verlassen der server allein für etwa 10 min die Verbindung verloren gegangen ist. Was könnte die Ursache sein? haben Sie versucht, die Einstellung

Wie zu konfigurieren und receiveAndConvert jSON-Nutzlast in das domain-Objekt im Frühjahr Starten und RabbitMQ

Anzahl der Antworten 2 Antworten
Vor kurzem habe ich ein großes Interesse an Microservice-Architektur mit Spring Boot. Meine Implementierung hat zwei Spring-boot-Anwendungen; Anwendung Einer empfängt Anforderungen von einem RESTful API, wandelt und sendet jSON-Nutzlast auf eine RabbitMQ queueA. Anwendung Zwei, hat abonniert

RabbitMQ Fehler in der config-Datei “/etc/rabbitmq/rabbitmq.config": syntax error before: ']'

Anzahl der Antworten 2 Antworten
Bin ich auf Ubuntu 14.04 installiert und ich rabbitmq. Als ich war das Lesen durch die Dokumentation, ich wollte meine eigenen rabbitmq.config-Datei in /etc/rabbitmq/rabbitmq.config, so suchte ich ein Beispiel für eine Konfigurationsdatei, welche ich gefunden unter /usr/share/doc/rabbitmq-server/rabbitmq.config.example.gz.

Veröffentlichen Sie mehrere Nachrichten zu RabbitMQ aus einer Datei

Anzahl der Antworten 5 Antworten
Publishing einzelnen Nachrichten zu einem RabbitMQ Warteschlange kann leicht getan werden mit der Benutzeroberfläche, indem Sie die Nachricht in der Benutzeroberfläche und klicken auf "Nachricht Veröffentlichen" - button. Wie veröffentlichen Sie einen Stapel von Nachrichten? Ich habe

Verteilt RabbitMQ Knoten nicht gegenseitig zu erkennen

Anzahl der Antworten 5 Antworten
Arbeite ich an einem RabbitMQ verteilt POC und ich bin stecken in die Grundlagen der Cluster-Knoten. Ich versuche zu Folgen, den Kaninchen tutorial auf clustering, so ist das meine Referenz. Nach der Installation von erlang (R14B04) und

konvertieren curl-Aufruf in java urlconnection nennen

Anzahl der Antworten 2 Antworten
Habe ich den curl-Befehl: curl -i -u guest:guest -H "content-type:application/json" -XPUT \ http://localhost:15672/api/traces/%2f/my-trace \ -d'{"format":"text","pattern":"#"}' Und ich möchte HTTP-Anfrage in Java-API, die das gleiche tun. Diese curl-Befehl finden Sie in diesem README. Es wird verwendet, um die

Rabbitmq-cluster funktioniert nicht auf ec2

Anzahl der Antworten 2 Antworten
Clustering mit Kaninchen funktioniert nicht. Ich meine wow..ich habe alle ports offen. Ich bin auf ubuntu 12.04 und noch bekomme ich das unter? Alle Kaninchen dev jemals Lesen Sie diese Beiträge...warum ist das so? Warum machen die

wie eine Verbindung zu rabbitmq mit ohne javascript nodejs

Anzahl der Antworten 2 Antworten
Ich bin Umsetzung einer mobile Anwendung mit Titanium appcelerator. In dieser app, werde ich brauchen, implementieren Sie einen chat mit RabbitMQ. Ich sah eine Menge von Beispielen, wie die Verbindung zu rabbitmq-server mit node js, aber in

mit mqtt-Protokoll mit kafka als einen message broker

Anzahl der Antworten 5 Antworten
Wie können wir verwenden mqtt-Protokoll mit kafka als message-broker? Den clients(android/ios/desktop-java-Anwendungen usw.) produzieren und konsumieren von Nachrichten mittels mqtt phao client-Seite-Bibliotheken, die verfügbar sind in verschiedenen Sprachen mit Hilfe von kafka als einen message broker. Irgendwelche Ratschläge?

RabbitMQ client-Lastausgleich

Anzahl der Antworten 3 Antworten
Ich bin Pilotierung rabbit mq und finde Sie ganz gut. Blick auf die HA Seite finde ich, dass die exchange/queue replication funktioniert gut. Ich bin beunruhigt durch die Tatsache, dass ich muss ein TCP Loadbalancer zur Verteilung

Das Lesen von mehreren Warteschlangen, RabbitMQ

Anzahl der Antworten 2 Antworten
Ich bin neu RabbitMQ. Ich möchte in der Lage sein zu handhaben, Nachrichten Lesen, ohne zu blockieren, wenn es mehrere Warteschlangen (Lesen). Alle Eingänge, wie kann ich das tun? //Edit 1 public class Rabbit : IMessageBus {

beste Weg, um zu drehen, rabbitmq-log-Dateien

Anzahl der Antworten 4 Antworten
Mein Kaninchen logs sind immer sehr groß und ich Frage mich, ob es einen besseren Weg zur Kontrolle der rotation. Ich würde gerne die logs zu rotieren basierend auf der Größe, und halten höchstens zehn Protokolle zu

RabbitMQ-Verbindung im blockierenden Zustand?

Anzahl der Antworten 2 Antworten
Ich eine Verbindung zu RabbitMQ-server meine Verbindung-Anzeige im blockierenden Zustand und ich nicht in der Lage, veröffentlichen Sie neue Nachricht ich habe ram von 6 gb frei und der Speicherplatz auch über 8GB konfigurieren von disk space

Installieren rabbitmqadmin auf linux

Anzahl der Antworten 3 Antworten
Ich versuche zu installieren und in der Lage zu laufen rabbitmqadmin auf einer linux-Maschine. Nach den Anweisungen beschrieben hier nicht helfen. Nach dem Download der Datei verknüpft sind, werden Sie aufgefordert, die Datei zu kopieren (sieht aus

RabbitMQ: Wie geben Sie den queue zu veröffentlichen?

Anzahl der Antworten 3 Antworten
RabbitMQ ist Channel#basicConsume Methode gibt uns die folgenden Argumente: channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback); Geben uns die Möglichkeit zu sagen, RabbitMQ genau die Warteschlange, die wir konsumieren wollen. Aber Channel#basicPublish hat keine solche äquivalenz: channel.basicPublish(exchangeName,

Azure Service Bus vs RabbitMQ für Enterprise-Anwendungen

Anzahl der Antworten 1 Antworten
Muss ich entscheiden zwischen Azure Service Bus und RabbitMQ (Bereitstellung auf Azure) für eine enterprise-level-Anwendung, und mein major Nutzung von Themen (mit dauerhaften Speicher). Ich sehe, dass service bus hat mehr Funktionen im Vergleich zu RabbitMQ wie

PHP Fatal error: Class 'AMQPConnection' nicht gefunden

Anzahl der Antworten 1 Antworten
Ich habe schon gesehen,diese Frage. Es deutet darauf hin, dass AMQP PECL-Erweiterung ist nicht installiert. Allerdings habe ich erfolgreich installiert, sowohl RabbitMQ sowie integrierte PECL AMQP-extension. Das folgende ist die Ausgabe von phpinfo(). Kann man deutlich sehen,

Senden Sie ein Objekt mit RabbitMQ

Anzahl der Antworten 1 Antworten
Ich Verstehe, dass diese Frage Duplikate Frage an mit rabbitmq eine Nachricht zu senden, nicht als string, sondern struct wenn dies mit der ersten Möglichkeit ersten Weise Habe ich die folgenden trace: java.io.EOFException at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2304) at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2773)

Warten auf eine Einzel-RabbitMQ-Meldung mit einem timeout

Anzahl der Antworten 5 Antworten
Ich würde gerne eine Nachricht senden, die eine RabbitMQ-server und warten dann auf eine Antwort-Nachricht ("reply-to" - Warteschlange). Natürlich, ich will nicht ewig warten, falls die Anwendung die Verarbeitung dieser Nachrichten ist down - muss es ein

Url-Codieren, Schrägstrich ( / ).NET

Anzahl der Antworten 4 Antworten
Wie kann ich erzwingen, entweder Uri oder HttpWebRequest zu ermöglichen, eine uri, die sowohl / und %2f wie die folgenden? http://localhost:55672/api/exchanges/%2f/MyExchange Habe ich versucht, dieses... WebRequest request = HttpWebRequest.Create("http://localhost:55672/api/exchanges/%2f/MyExchange"); ...und diese... Uri uri = new Uri("http://localhost:55672/api/exchanges/%2f/MyExchange", true);

RabbitMQ gestartet, aber keinen Zugriff auf die management-Schnittstelle

Anzahl der Antworten 3 Antworten
Habe ich Rabbit MQ gestartet und installiert. Der Dienst läuft auch. Jedoch, wenn ich versuche, öffnen Sie die management-Schnittstelle in firefox, ich bekomme diese Fehlermeldung: Firefox kann keine Verbindung zu dem server unter localhost:#####. (##### werden mehrere

Fehler mit rabbit-mq server

Anzahl der Antworten 5 Antworten
Ich bin versucht, setup-OpenStack auf Ubuntu 12.04 mit devstack. Nun, der Fehler den ich erhalte ist: Setting up rabbitmq-server (2.7.1-0ubuntu4) ... Starting rabbitmq-server: FAILED - check /var/log/rabbitmq/startup_{log, _err} rabbitmq-server. invoke-rc.d: initscript rabbitmq-server, action "start" failed. dpkg: error

Rabbitmq abrufen mehrerer Nachrichten über eine einzige synchronen Aufruf

Anzahl der Antworten 4 Antworten
Ist es ein Weg, um erhalten mehrere Nachrichten mit einem einzigen synchronen Aufruf ? Wenn ich weiß, dass es N Nachrichten( N könnte einen kleinen Wert, kleiner als 10) in der Warteschlange, dann sollte ich in der

Verschieben von Nachrichten zwischen Warteschlangen rabbitMQ

Anzahl der Antworten 3 Antworten
Ich bin auf der Suche, um in der Lage sein, um Nachrichten zwischen Warteschlangen (manuell), Kaninchen. Beispiel: first-queue has messages ['a','b','c','d','e','f'] second-queue has messages ['x','y'] Ich möchte in der Lage sein, sich zu bewegen zum Beispiel Meldung

RabbitMQ set_permissions syntax noob

Anzahl der Antworten 2 Antworten
Habe ich gesehen, die anderen Beiträge auf stackoverflow in irgendeiner Weise auf die lächerliche Frage, die ich bin, zu Fragen, aber keiner von Ihnen verdummt es nach unten genug für mich zu bekommen, was ich gesucht hatte.

Ausnahme 'Der AMQP-Vorgang wurde unterbrochen' (code=406) vorkommt .NET-Client-Programmierung

Anzahl der Antworten 1 Antworten
Ich habe einen 2.8.2 RabbitMQ-Server und einem 2.8.2 client dll, habe den code zum deklarieren einer Warteschlange und die Meldung erhalten, es funktioniert einwandfrei (alle Parameter korrekt sind): IModel channel=null; ConnectionFactory factory = new ConnectionFactory (); factory.HostName