rabbitmq

0Hitze

1Antwort

Wie Routing Schlüssel dynamisch im Frühjahr xd angeben, für RabbitMQ

I routingkey Wert von RabbitMQ Sink in SpringXD mit '{$ payload.routingkey'} Als Nutzlast zu setzen versuchen trägt die gesamte Nachricht, Meine Botschaft ist ein json { "routingkey": "Disney", "text"

1Hitze

2Antwort

Wie lösche ich alle Nachrichten von rabbitmq mit Hilfe der Knotenbibliothek?

Ich möchte alle Nachrichten aus der Hase-mq-Warteschlange löschen, bevor ich anfange, Daten in sie zu schieben. Wie kann dies erreicht werden? Ich verwende https://www.npmjs.com/package/amqplib

0Hitze

1Antwort

RabbitMQ, ist es möglich, 1 Nachricht von einem Kanal zu verbrauchen, während es FIFO?

Ich verwende RabbitMQ mit C# als Message Broker Framework. In meinem Szenario habe ich viele Verbraucher, die aus verschiedenen Warteschlangen verbrauchen können. mehrere Warteschlangen bilden eine lo

0Hitze

1Antwort

RabbitMQ Warteschlangenspeicherplatznutzung im Fanout-Austauschszenario

Wenn der RabbitMQ-Broker einen Fanout-Austausch mit vielen daran gebundenen Warteschlangen hat, die Warteschlangen dauerhaft sind und die an die Exchange ausgelieferten Nachrichten dauerhaft sind, wir

6Hitze

2Antwort

Installieren Sie Rabbitmqadmin auf Linux

Ich versuche zu installieren und in der Lage sein, rabbitmqadmin auf einem Linux-Rechner ausführen. Befolgen Sie die Anweisungen here nicht helfen. Nach dem Herunterladen der verknüpften Datei werden

-1Hitze

1Antwort

Verbindung versagt zwischen Raspberry Pi und Mac

Ich habe folgendes a) ein rabbitmq-Server und Pika auf einem Mac Yosrmite Maschine installiert. Ich habe einen rabbutmq.config /usr/local/etc/rabbitmq/rabbitmq.config, dass ich die Aussage haben: {loo

0Hitze

1Antwort

rabbitmq drücke nicht die Nachricht in der Warteschlange. Node.JS

Hier ist, wie ich die Verbindung mache. Mit node.js und AMQP Modul this.conn.exchange(name, options, function(ex) { console.log('Exchange ready'); this.exchange = ex; var next = this.c

1Hitze

1Antwort

RabbitMQ Consumer-Verbindung zu rabbitMQ in https-Domäne

Ich muss Nachrichten einer Warteschlange empfangen, aber diese Warteschlange ist in einem anderen Computer (AWS-Instanz) mit https (https://www.mymachine.com/rabbitmq), aber wenn ich eine Verbindung z

2Hitze

1Antwort

rabbitmq löscht die Warteschlangenbindung nach dem Neustart des Servers.

Ich verwende Hase, um die rabbitmq-Warteschlange einzurichten. namespace :rabbitmq do desc 'Setup routing' task :setup_test_commands_queue do require 'bunny' conn = Bunny.new(ENV[

0Hitze

1Antwort

Fügen Sie die Standardmethode vor dem Aufruf von onMessage hinzu, wenn MessageListener von Spring Amqp

Ich muss einige Standardfunktionalität hinzufügen, die auf einen Wert aus Nachrichtenheader in Spring Amqp vor dem Aufrufen der Funktion MessageMessage der implementierenden Klasse auswählen. Eg class