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.
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,
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
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
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.
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
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
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
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
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
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
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
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
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
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" -
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
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
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
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 |
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
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
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
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
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
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
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
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
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.
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
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
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
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
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
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?
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
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 {
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
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
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
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,
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
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,
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)
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
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);
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
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
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
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
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.
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