amqp

AMQP ist ein offener Nachrichtenstandard. Es definiert ein Wire-Level-Protokoll und einen semantischen Rahmen für Hochleistungs-Enterprise-Messaging. Wenn Sie einen bestimmten Broker verwenden (z. B. [rabbitmq]), kann das AMQP-Tag redundant sein. AMQP sollte nicht mit Apache verwechselt werden [ActiveMQ]
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
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

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

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
1
Antwort

RabbitMQ: Was ist der Standardwert für x-message-ttl?

Ich konnte in der RabbitMQ-Dokumentation den Standard-x-message-ttl-Wert nicht finden, der mit der Installation mitgeliefert wird. Ich weiß, wie ich es auf einen gewünschten Wert einstellen kann, aber ich bin neugierig, den Standardwert zu ke...
25.07.2014, 00:30
3
Antworten

Wiederherstellen von zmq.error.ZMQError: Adresse wird bereits verwendet

Ich habe Strg-C gedrückt, während ich eine PAIR -Muster-Verbindung (nicht blockierende Client-Server) mit ZMQ ausgeführt habe. Später, als ich versuchte, das Muster REQ-REP (Client-Einzelserververbindung blockieren) auszuführen, erhalte ic...
03.10.2013, 12:54
2
Antworten

Abonniere eine Warteschlange, empfange 1 Nachricht und melde sich dann ab

Ich habe ein Szenario, in dem ich Jobs extrem schnell verteilen und bearbeiten muss. Ich werde ungefähr 45 Jobs in der Warteschlange schnell haben und ich kann ungefähr 20 gleichzeitig bearbeiten (5 Maschinen, 4 Kerne). Jeder Job benötigt eine v...
15.04.2011, 23:13
1
Antwort

Was bedeutet jetzt in RabbitMQ's exchange.declare ()?

Ziemlich einfache Frage. Ich kann es nicht in den Dokumenten oder in der Spezifikation finden.     
15.06.2011, 00:21
1
Antwort

AMQP-Abonnent in der Rails-App

Kann ich einen AMQP-Abonnenten mit meiner Rails-App starten? Möglicherweise durch einen Initialisierer oder etwas. Ich möchte es zur gleichen Zeit laufen lassen, die auch mit Rails-Modellen interagieren kann. Unten ist ein Pseudo-Code-Beispie...
14.05.2010, 15:00
1
Antwort

In einem FIFO-Qeueing-System ist es am besten, Priority Messaging zu implementieren

Für Message-orientierte Middleware, die Prioritätsnachrichten (wie AMQP) nicht konsistent unterstützt, was ist der beste Weg, Prioritätsverbrauch zu implementieren, wenn Warteschlangen nur FIFO-Semantik haben? Der allgemeine Anwendungsfall wäre...
16.07.2009, 17:48