Senden von Nachrichten an die exklusive Warteschlange mit AMQP/RabbitMQ

Question

Ich habe eine Reihe von Computern, die einige Aktionen ausführen können. Um eine Aktion zu initiieren, möchte ich eine Nachricht an eine Warteschlange senden, die beispielsweise von der Rechner-ID "12345" benannt wird.

Um zu vermeiden, dass jemand anderes diese Nachrichten konsumiert, sollte die Warteschlange exklusiv sein, denke ich.

Aber von meinem Controller kann ich die Warteschlange nicht geltend machen, wenn sie auf dem Rechner, der sie verbraucht, als exklusiv erklärt wird. Ich kann jedoch in die Warteschlange senden, indem ich seinen Namen festlege, ohne zu behaupten, aber ich denke, das ist eine schlechte Übung?

Die Maschine ist für Befehle wie diese hört:

ch.assertQueue(machineID, {exclusive: true, durable: false}, function (err, q) { 
    if (err) console.log(err) 
    console.log("opened queue") 
    ch.consume(q.queue, function (message) { 
     console.log(message.content.toString()) 
    }) 
}) 

Wenn ich an die Warteschlange senden, wird es aufgrund exklusive Fragen scheitern, an dieser Linie im Client:

ch.assertQueue(machineID, {}) 

Aber Es wird die Nachricht senden, wenn ich die Zeile oben kommentiere.

ch.sendToQueue(machineID, new Buffer(id.toString())) 

Was ist der eleganteste Weg, um dies zu umgehen?

Answer 1

Eine Möglichkeit besteht darin, einen Austausch vom Typ 'direkt' zu erstellen und die Warteschlange an diesen Austausch zu binden. Wenn Sie also eine Nachricht an diese Vermittlungsstelle übergeben, wird sie nur an diese Warteschlange weitergeleitet, deren Name mit dem Routing-Schlüssel identisch ist, den Sie an die Vermittlungsstelle übergeben. Beispielsweise werden alle Nachrichten mit dem Routing-Schlüssel "12345" von einer solchen Vermittlungsstelle an die Warteschlange mit der Bezeichnung "12345" weitergeleitet.