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.

REST-API für rabbitmq

Anzahl der Antworten 3 Antworten
Gibt es einen Weg, wie kann ich Daten senden, RabbitMQ von $.ajax? Meine Anwendung besteht aus mehreren tausenden von web-clients (geschrieben auf js) und WCF-REST-Dienst, und jetzt versuche ich, herauszufinden, wie kann ich erstellen Sie eine skalierbare

Python und RabbitMQ - Beste Weg, um hören zu konsumieren Ereignisse, die von mehreren Kanälen?

Anzahl der Antworten 2 Antworten
Habe ich zwei, separate RabbitMQ-Instanzen. Ich bin versuchen zu finden der beste Weg, um zu hören, um Ereignisse aus beiden. Ich kann zum Beispiel verbrauchen Ereignisse zu eins mit dem folgenden: credentials = pika.PlainCredentials(user, pass) connection =

Ermöglicht RabbitMQ-Server-Verbindungen

Anzahl der Antworten 1 Antworten
Ich versuche zu bekommen eine Django-Celery-Arbeiter, um eine Verbindung zu einem RabbitMQ-server laufen alle auf dem gleichen host. Jedoch, wenn ich manage.py celery worker alles was ich bekomme ist: [2013-06-11 17:33:41,185: WARNING/MainProcess] celery@localhost has started. [2013-06-11 17:33:44,192:

RabbitMQ-cluster nicht wiederherstellen der Verbindung nach Netzwerk-Ausfall

Anzahl der Antworten 3 Antworten
Ich habe RabbitMQ-cluster mit zwei Knoten, die in der Produktion und der cluster bricht mit folgenden Fehlermeldungen: =ERROR REPORT==== 23-Dec-2011::04:21:34 === ** Knoten rabbit@rabbitmq02 reagiert nicht ** ** Entfernen (timedout) - Anschluss ** =INFO REPORT==== 23-Dec-2011::04:21:35 ===

Wie man Spring-RabbitMQ zum erstellen einer neuen Warteschlange?

Anzahl der Antworten 3 Antworten
In meine (begrenzte) Erfahrung mit rabbit-mq, wenn Sie einen neuen listener für eine Warteschlange, die noch nicht existiert, wird die Warteschlange automatisch erstellt. Ich versuche, das Spring AMQP-Projekt mit rabbit-mq um einen listener einrichten, und ich bekomme

RabbitMQ verbrauchen Sie eine Nachricht, wenn vorhanden und beenden

Anzahl der Antworten 1 Antworten
Ich bin das ausführen von code auf python-senden und empfangen von RabbitMQ Warteschlange aus einer anderen Anwendung, wo ich kann nicht erlauben, dass threading. Dies ist sehr newbie-Frage, aber gibt es eine Möglichkeit nur überprüfen, ob die

Curl zu bekommen, Rabbitmq Warteschlange Größe

Anzahl der Antworten 4 Antworten
Ist es ein Weg, um die Größe der (Rest-Nachrichten) von einer queue rabbitmq mit einer einfachen Curl? Etwas wie curl -xget http://host:1234/api/queue/test/stats Danke InformationsquelleAutor tbo | 2014-06-25

Eingebettet AMQP Broker-Java

Anzahl der Antworten 5 Antworten
Ich versuche zu erstellen, integration-test für eine Scala /Java-Anwendung, die eine Verbindung zu einem RabbitMQ-broker. Um dies zu erreichen möchte ich einen embedded-broker, spricht AMQP, dass ich starten und stoppen Sie vor jedem test. Ursprünglich wollte ich

Windows x64 installieren RabbitMQ Fehler mit Erlang-Umgebung var (ERLANG_HOME)

Anzahl der Antworten 8 Antworten
Ich bin Fragen/beantworten diese Frage, denn es hing mir bis & es ist wahrscheinlich, jemand anderes das gleiche problem haben. Installation von RabbitMQ-x64-v2.8.6 auf Windows Server 2008 x64. Nach Erlang installieren, mit Standard-Installationsort an C:\Program Dateien\erl5.9.2, ich

Consumer Connection error mit django und Sellerie+rabbitmq?

Anzahl der Antworten 5 Antworten
Ich versuche bis celeryd mit django und rabbit-mq. Bisher habe ich Folgendes getan: Installiert Sellerie aus der pip - Installierten rabbitmq über die debs verfügbar, von seinem Depot Hinzugefügt, ein Benutzer-und vhost zu rabbitmq über rabbitmqctl, sowie

Ack-oder Nack in rabbitMQ

Anzahl der Antworten 2 Antworten
Ich bin mit rabbitMQ, ich nehme jede Nachricht aus der Warteschlange mit basic_get ohne automatisch durch ACK bestätigt Verfahren, was bedeutet, dass die Nachricht verbleibt in der Warteschlange bis ich auf ack oder nack der Nachricht. Manchmal

Nicht in der Lage zu Starten, rabbitmq-server in centos 7 mit systemctl

Anzahl der Antworten 3 Antworten
Ich versuche, starten Sie den rabbitmq-server in centos 7. Ich installierte erlang, wie es ist, eine Abhängigkeit zu rabbitmq-server. Paket erlang.x86_64 0:R16B-03.7.el7 .Ich habe dann Installiert rabbitmq mit dem Paket-rabbitmq-server-3.2.2-1.noarch.U /min. Installation erfolgreich war. Ich fähigen management

Sellerie Zeitplan für die Aufgabe (Sellerie, Django und RabbitMQ)

Anzahl der Antworten 6 Antworten
Ich will eine Aufgabe, die ausgeführt wird, alle 5 Minuten, aber es wird warten, für die Letzte Ausführung beendet ist, und dann zählen diese 5 Minuten. (So kann ich auch sicher sein, dass es nur eine task

RabbitMQ neue Verbindung abgelehnt aufgrund SocketException

Anzahl der Antworten 3 Antworten
während versuchen, um eine neue Verbindung zu rabbitmq auf einem anderen server läuft, bekam ich die folgende Fehlermeldung: java.io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:406) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533) Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason:

RabbitMQ "Hello World" - Beispiel gibt "Connection Refused"

Anzahl der Antworten 7 Antworten
II versuche zu machen, die "hello world" - Anwendung von hier: RabbitMQ Hallo Welt Hier ist der code von meinem Produzenten Klasse: package com.mdnaRabbit.producer; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; import java.io.IOException; public class App { private

RabbitMQ - Holen Sie sich die Gesamtzahl der Nachrichten in die Warteschlange eingereiht

Anzahl der Antworten 3 Antworten
Ich habe ein Java-client, der überwacht RabbitMQ Warteschlange. Ich bin in der Lage, um die Anzahl von Meldungen, die sich derzeit in der Warteschlange mit diesem code @Resource RabbitAdmin rabbitAdmin; .......... DeclareOk declareOk = rabbitAdmin.getRabbitTemplate().execute(new ChannelCallback<DeclareOk>() {

Erste Reihe von Nachrichten in einer queue RabbitMQ

Anzahl der Antworten 3 Antworten
Verwenden wir amqplib zu veröffentlichen/konsumieren von Nachrichten. Ich möchte in der Lage sein zu Lesen, die Anzahl der Nachrichten in einer Warteschlange (idealerweise beide bestätigten und unbestätigten). Dies wird mir erlauben, zu zeigen, eine schöne status-Diagramm der

Wie man RabbitMQ Warteschlangen failover?

Anzahl der Antworten 3 Antworten
RabbitMQ unterstützt clustering standardmäßig, aber Warteschlangen nicht repliziert werden und sind an den Knoten, auf dem Sie geschaffen sind. Ich bin nun auf der Suche nach Möglichkeiten, um RabbitMQ hoch verfügbar andere als die DRBD-Lösung, die Sie

Sellerie: Fehler bei der Verbindung zu RabbitMQ-Server

Anzahl der Antworten 2 Antworten
Bin ich angefangen zu verwenden, Sellerie, indem Sie die folgenden dieses "Erste Schritte mit Sellerie". Ich genau die tasks.py angegeben link an. Jedoch, wenn lief ich die Aufgabe mit, celery -A tasks worker --loglevel=info Bin ich immer

Warum ist RabbitMQ nicht persistenten Nachrichten auf einem dauerhaften Warteschlange?

Anzahl der Antworten 3 Antworten
Ich bin mit RabbitMQ mit Django durch Sellerie. Ich bin mit dem meisten basic-setup: # RabbitMQ connection settings BROKER_HOST = 'localhost' BROKER_PORT = '5672' BROKER_USER = 'guest' BROKER_PASSWORD = 'guest' BROKER_VHOST = '/' Ich importierte eine Sellerie

Unterschied zwischen stream-Verarbeitung und die message-Verarbeitung

Anzahl der Antworten 2 Antworten
Was ist der grundlegende Unterschied zwischen stream-Verarbeitung und traditioneller message-Verarbeitung? Wie die Leute sagen, dass kafka ist eine gute Wahl für die stream-Verarbeitung, sondern im wesentlichen kafka ist ein messaging-framework, ähnlich ActivMQ, RabbitMQ etc. Warum tun wir

rabbitmqctl Fehler: konnte keine Verbindung zum Knoten rabbit@myserver nodedown

Anzahl der Antworten 4 Antworten
Ich bin mit RabbitMQ v3.3.5 mit Erlang OTP 17.1 auf Windows 2008 R2. Mein Dev-und QA-Umgebungen sind stand-alone. Meine staging-und Produktionsumgebungen gruppiert sind. Ich finde dies ein problem, das passiert oft, wo die RabbitMQ-Dienst ausgeführt wird, ist

RabbitMQ: Nachrichten bleiben "Unbestätigten"

Anzahl der Antworten 2 Antworten
Meine Java-Anwendung sendet Nachrichten zu RabbitMQ exchange, dann leitet exchange Nachrichten an gebundenen Warteschlange. Ich benutze Springframework AMQP java-plugin mit RabbitMQ. Das problem: kommt die Meldung in die Warteschlange, aber es bleibt in "Uneingestandene" - Zustand, es

RabbitMQ + Memory Limits

Anzahl der Antworten 1 Antworten
Ich bin gerade auf der Suche in der config-details von RabbitMQ und kam über [{rabbit, [{vm_memory_high_watermark, 0}, {disk_free_limit, {mem_relative, 1.0}} ] }] Was bedeutet diese config bedeuten? vm_memory_high_watermark auf 0 gesetzt bedeutet, dass => Block alle Verlage

Nicht aktivieren Sie die rabbitmq-management-Plug-in für Windows

Anzahl der Antworten 7 Antworten
So, das ist, was ich getan habe: Installiert Erlang auf meinem Windows x64-bit-Maschine Installierten RabbitMQ Begann RabbitMQ service In diesem Schritt habe ich keine Fehler. Wenn ich jedoch versuchen, enabe rabbitmq-management, erhalte ich einige Fehlermeldungen in der

Gibt es einen Leistungsunterschied zwischen pooling-verbindungen oder Kanäle in rabbitmq?

Anzahl der Antworten 3 Antworten
Ich bin ein Neuling mit dem Rabbitmq - (und Programmier -) also sorry im Voraus, wenn diese offensichtlich ist. Ich Schaffe einen pool teilen zwischen threads, die auf eine Warteschlange, aber ich bin mir nicht sicher, ob

Gibt es irgendwelche guten alternativen zu RabbitMQ für low-end-setups?

Anzahl der Antworten 3 Antworten
Habe ich mit RabbitMQ in ein paar setups jetzt, und ich kann nicht erschüttern das Gefühl, dass es etwas sein muss, das ist eher einfach eingerichtet. Trotz der Bequemlichkeiten, es ist schwer zu rechtfertigen, MQ für eine

MongoDB-Schema-Design - Echtzeit-Chat

Anzahl der Antworten 3 Antworten
Fange ich ein Projekt, von dem ich glaube, dass Sie besonders gut geeignet, um MongoDB aufgrund der Geschwindigkeit und Skalierbarkeit, die es gewährt. Dem Modul bin ich derzeit daran interessiert ist, zu tun, Echtzeit-chat. Wenn ich dies

RabbitMQ - auf eine neue version aktualisiert und bekam eine Menge von "PRECONDITION_FAILED unbekannten Lieferung-tag 1"

Anzahl der Antworten 2 Antworten
Nur ein Upgrade auf eine neue version von RabbitMQ -- 2.3.1 -- und nun tritt folgender Fehler auf: PRECONDITION_FAILED unknown delivery tag 1 ...gefolgt von der Kanal schließen. Dieser arbeitete auf einem älteren RabbitMQ mit der client-Seite

Fehlermeldung "unbekannter Lieferzeit-tag" tritt auf, wenn ich versuche ack-Nachrichten zu RabbitMQ mit pika (python)

Anzahl der Antworten 5 Antworten
Möchte ich die Verarbeitung von Nachrichten in paar threads aber ich bin immer ein Fehler während der Ausführung dieses Codes: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika import connection, credentials

Erholsamen v/s MQ. Unterschiede und anderen wichtigen Funktionen, abgesehen von der Garantierten Lieferung

Anzahl der Antworten 3 Antworten
Ok..Also ich habe angefangen zu studieren, MQ und Ihr Zweck/Anwendungsfall etc... Meine bestehende Anwendung (Web mit JSP, etc..) verwendet RestFUL-Schnittstelle für die Kommunikation mit einem remote-server und post/Daten vom server empfangen. Wir oft zu tun haben mit

Wie Sie sich alle Rabbit MQ-Nachrichten?

Anzahl der Antworten 1 Antworten
Sind wir mit einem RabbitMQ-server für messaging zwischen Anwendungen. Wir haben ein Bedürfnis zu schaffen, ein zentrales Protokoll für alle amqp-Nachrichten kommen in der Hase-server. Unser Ziel ist, nicht nur vorübergehend, Debuggen, sondern die Nachvollziehbarkeit. Im Idealfall,

RabbitMQ Deklarieren Austausch von Terminal - Zugriff verweigert: /api/Austausch/

Anzahl der Antworten 2 Antworten
Ich bin mit rabbitmq zu handhaben von Nachrichten zwischen meine Datenbanken für eine enterprise-Anwendung, mit der ich arbeiten kann. Als Teil des Prozesses, ich versuche zu helfen, automatisieren der Installation von Servern (z.B. Skript). In diesem Prozess,

Wie setze ich eine Anzahl der Wiederholungsversuche in RabbitMQ?

Anzahl der Antworten 1 Antworten
Ich bin mit RabbitMQ und ich habe eine Warteschlange, in der E-Mail-Nachrichten. Meine Verbraucher-service-de-Warteschlangen-Nachrichten und versucht, Sie zu senden. Wenn, aus irgendeinem Grund, meine Verbraucher nicht die Nachricht zu senden, möchte ich erneut in die Warteschlange der

Verbrauchen nicht anerkennen Nachrichten von RabbitMq

Anzahl der Antworten 2 Antworten
Habe ich ein einfaches erstellen Verleger und Verbraucher, die ein Abonnent in der Warteschlange mit basic.consume. Meine Verbraucher erkennt die Nachrichten, wenn der job läuft, ohne eine Ausnahme. Wann immer ich eine Ausnahme ich nicht der ack-Nachricht

RabbitMQ: schnell Produzent und Verbraucher langsam

Anzahl der Antworten 5 Antworten
Ich habe eine Anwendung, die verwendet RabbitMQ als message-queue zum senden/empfangen von Nachrichten zwischen zwei Komponenten: sender und Empfänger. Der sender sendet Nachricht in eine sehr schnelle Art und Weise. Der Empfänger erhält die Nachricht und macht

Rabbitmq server-Verbindung schließen abrupt

Anzahl der Antworten 2 Antworten
Habe ich versucht, Rabbitmq-server aus irgendeinem Grund die Verbindung beendet abrupt, obwohl ich an der richtigen Benutzername und Passwort. Rabbitmq-server läuft auf port 5672 und telneting zu meinem server auf port 5672 sagt seiner läuft gut. Habe

Überprüfen Sie die version von rabbitmq

Anzahl der Antworten 11 Antworten
Wie kann ich überprüfen, welche version von rabbitmq auf einem server läuft? Gibt es einen Befehl, um zu überprüfen, dass rabbitmq läuft? InformationsquelleAutor der Frage Hussain Fakhruddin | 2011-09-29

RabbitMQ : wie zum erstellen und wiederherstellen von backup

Anzahl der Antworten 2 Antworten
Ich bin neu RabbitMQ und ich brauche etwas Hilfe. wie, um Sicherung und Wiederherstellung zu RabbitMQ, und was ist die wichtigsten Informationen, die ich brauche, um zu sparen. Dank! InformationsquelleAutor der Frage lior | 2013-10-28

Wann RabbitMQ Schaufeln und wenn die Föderation plugin?

Anzahl der Antworten 2 Antworten
Für die Firma für die ich arbeite, würden wir gerne verwenden, RabbitMQ als message-bus. Die Idee, die wir haben, ist, dass jede einzelne Anwendung verwendet Ihre eigenen vhost für die interne Kommunikation und das über die Schaufel

RabbitMQ Benutzer die Berechtigung format

Anzahl der Antworten 2 Antworten
Ich versuche das konfigurieren von Benutzer-Berechtigungen in RabbitMQ mit rabbitmqctl. Der RabbitMQ-Dokumentation http://www.rabbitmq.com/man/rabbitmqctl.1.man.html gibt ein einfaches Beispiel für die Einstellung konfigurieren, schreiben und Lesen Berechtigungen: rabbitmqctl set_permissions -p /myvhost tonyg "^tonyg-.*" ".*" ".*" aber geben nicht mehr

Löschen Sie alle Warteschlangen von RabbitMQ?

Anzahl der Antworten 18 Antworten
Ich installiert rabbitmqadmin und war in der Lage, um eine Liste der Börsen und Warteschlangen. Wie kann ich rabbitmqadmin oder rabbitmqctl löschen Sie alle Warteschlangen. InformationsquelleAutor der Frage Cory | 2012-07-12

AMQP vs Websphere MQ

Anzahl der Antworten 2 Antworten
Wir arbeiten an einer Anwendung, die unterstützt AMQP für queuing. Einige unserer Kunden werden mithilfe von Websphere MQ. Ich Frage mich nur, auf einem hohen Niveau, wie austauschbar diese beiden Protokolle sind in Bezug auf Funktionalität. Ich

RabbitMQ, Pika und reconnection-Strategie

Anzahl der Antworten 1 Antworten
Bin ich mit Pika, um Prozess Daten von RabbitMQ. Als ich schien zu laufen, in verschiedene Art von Problemen habe ich mich dazu entschlossen eine kleine test-Anwendung, um zu sehen, wie ich damit umgehen kann, trennt. Schrieb

Löschen von Warteschlangen in RabbitMQ

Anzahl der Antworten 13 Antworten
Habe ich ein paar Warteschlangen laufen mit RabbitMQ. Ein paar von Ihnen sind von keinerlei nutzen ist nun, wie kann ich diese löschen? Leider hatte ich nicht die auto_delete option. Wenn ich es jetzt, wird es gelöscht

Wie Sie Zugang zu RabbitMq öffentlich

Anzahl der Antworten 3 Antworten
Habe ich installiert & setup der Rabbitmq auf Centos remote-server. Später erstellte ich eine Datei "rabbitmq.config" und fügte hinzu, die Linie [{rabbit, [{loopback_users, }]}] und dann neu gestartet, die rabbitmq-server. Wieder versucht zu login des rabbitmq-management-web-interface von

Mit RabbitMQ gibt es eine Möglichkeit zu schauen, queue-Inhalte ohne eine dequeue?

Anzahl der Antworten 3 Antworten
Als ein Weg, um zu lernen, RabbitMQ und python ich arbeite an einem Projekt, das mir erlaubt, zu verteilen, h264 kodiert, die zwischen einer Anzahl von Computern. Die Grundlagen sind getan, ich habe einen daemon, der läuft

RabbitMQ AMQP.BasicProperties.Builder-Werte

Anzahl der Antworten 3 Antworten
In der RabbitMQ/AMQP-Java-client, erstellen Sie eine AMQP.BasicProperties.Builderund es verwenden, um build() eine Instanz von AMQP.BasicProperties. Diese integrierten Eigenschaften-Instanz kann dann verwendet werden, um alle Arten wichtiger Dinge. Es gibt viele "builder"-Stil Methoden zur Verfügung, die auf diese

Performance-Vergleich zwischen ZeroMQ, RabbitMQ und Apache Qpid

Anzahl der Antworten 8 Antworten
Brauche ich ein high-performance-message-bus für meine Anwendung also ich bin die Evaluation der performance von ZeroMQRabbitMQ und Apache Qpid. Zur Messung der performance, bei mir läuft ein Testprogramm veröffentlicht, die sagen, 10.000 Nachrichten mit Hilfe einer der

So erstellen Sie eine verzögerte queue RabbitMQ?

Anzahl der Antworten 5 Antworten
Was ist der einfachste Weg, eine delay (oder Parkplatz) - Warteschlange mit Python, Pika und RabbitMQ? Ich habe gesehen, dass ähnliche Fragenaber keine für Python. Ich finde das eine sehr nützliche Idee, beim entwerfen von Anwendungen, er