rabbitmq

RabbitMQ ist ein Open-Source-Nachrichtenbroker, der ursprünglich das AMQP-Protokoll mit zusätzlichen Nachrichtenprotokollen implementiert, die über eine Plug-in-Architektur unterstützt werden. Dieses Tag sollte bei Fragen verwendet werden, die das Message Broker-Produkt des RabbitMQ-Servers betreffen, oder bei Fragen zum Quellcode und zur Implementierung des RabbitMQ-Produkts. Ein bestimmtes Protokoll-Tag, wie beispielsweise amqp oder mqtt, kann ebenso geeignet sein wie das Betriebssystem und die verwendete Programmiersprache.
3
Antworten

Wann der direkte Austausch über den Fanout-Austausch verwendet werden soll

Soweit ich das beurteilen kann, gibt es keinen richtigen Benutzerfall für einen direkten Austausch, da alles, was Sie damit tun können, Sie mit einem Fanout-Austausch tun können, nur erweiterbarer. Genauer gesagt beziehen sich die Autoren bei...
26.02.2013, 23:41
2
Antworten

Django Sellerie Beat Admin Update Cron Zeitplan Periodische Task nicht wirksam

Ich betreibe eine Website mit Django 10, RabbitMQ und Sellerie 4 auf CentOS 7. Meine Sellerie-Beat- und Sellerie-Worker-Instanzen werden vom Supervisor gesteuert und ich benutze den Django-Sellerie-Datenbank-Scheduler. Ich habe eine Cron-S...
13.11.2016, 23:04
1
Antwort

bad_header für die AMQP-Verbindung beim Verbinden von sensu-client mit server

Ich habe sensu mit Kochkochbuch der Gemeinde installiert. Der sensu Client kann jedoch keine Verbindung zum Server herstellen. Ergebnisse im rabbitmq-Verbindungsfehler mit Zeitüberschreitung der Nachricht beim Versuch, eine Verbindung herzustell...
08.07.2014, 13:01
1
Antwort

RabbitMQ 3.6.1 / Erlang 18.3 TLS unzureichende Sicherheitsfehler

Ich führe RabbitMQ 3.6.1 / Erlang 18.3 aus und stelle fest, dass ich mit dem Broker, der den Spring AMQP 1.5.4.RELEASE Java-Client verwendet, keine TLSv1- oder TLSv1.1-Sitzung einrichten kann. Ich bin jedoch in der Lage, eine TLSv1.2-Sitzung mit...
22.04.2016, 03:38
2
Antworten

Wie kann ich bei Sellerie verhindern, dass lange verzögerte Aufgaben neue blockieren?

Ich habe zwei Arten von Aufgaben. Aufgabe A wird jede Stunde durch Selleriebeat erzeugt. Es wird sofort ausgeführt und generiert tausend (oder viele tausend) Instanzen von Task B, von denen jede eine ETA von einem Tag in der Zukunft hat. Beim...
13.05.2014, 15:39
2
Antworten

Node-amqp - Zurückweisung der Nachricht nach X-Versuchen

Wie implementiere ich einen Mechanismus, der eine Nachricht nach einigen konfigurierbaren Wiederholungsversuchen zurückweist? Mit anderen Worten, wenn ich eine Warteschlange abonniere, möchte ich garantieren, dass die gleiche Nachricht nicht...
13.02.2014, 16:27
1
Antwort

Demultiplexen von Nachrichten aus einer Warteschlange zur Verarbeitung in parallelen Streams mit amqp?

Ich versuche herauszufinden, ob ich von einem blockierenden Szenario zu einem reaktiveren Muster wechseln kann. Ich habe eingehende Update-Befehle, die in einer Warteschlange ankommen, und ich muss sie in der Reihenfolge behandeln, aber nur d...
17.07.2014, 08:32
1
Antwort

RabbitMQ IOError: Socket geschlossen

Ich habe einen RabbitMQ-Nachrichtenbroker und einen entfernten Sellery-Mitarbeiter. Es funktioniert gut, aber etwa alle fünf Minuten bekomme ich diesen Fehler: %Vor% Dies ist das Init-Skript, das ich benutze, um einen Sellerie-Deamon zu star...
06.01.2014, 14:08
1
Antwort

Fortsetzen von Jobs in der Warteschlange, nachdem der NodeJS-Worker auf Heroku neu gestartet wurde

Ich habe also ein ziemlich einfaches Setup auf Heroku . Ich benutze RabbitMQ für die Bearbeitung von Hintergrundjobs. Mein Setup besteht aus einem Knotenscript, das täglich mit dem Heroku Scheduler Addon läuft. Die Skripts fügen Jobs zur Wa...
21.09.2016, 07:37
1
Antwort

Wie gehe ich mit RabbitMQ Consumer Cancellation Notification um, wenn Spring ChannelAwareMessageListener verwendet wird?

Newbie zu RabbitMQ und neu zu Java. Ich versuche, einen Listener zu schreiben, der manuelle Acks verwendet und Benachrichtigungen über Kundenunterbrechungen mit der java Spring AMQP Abstraktion handhabt. Kann ich beide Aufgaben mithilfe der S...
12.06.2013, 20:16