RabbitMqバインディング

Question

私はそれが間違っているかもしれないことを実感しますが、ここで私を修正するチャンスがあります！

Iは、デバイスを持っている - と言う... 60. 装置60はIデバイスからメッセージを受信し、メッセージヘッダ内のIDであるマスター2

によって処理されるのIDを持ちます。しかし、この段階で私のプログラムは、デバイスが割り当てられているマスターを知りません。

デバイス60のすべてのメッセージを、「Device60」というRabbitMqキューに入れたいと思っています。この時点では、何もそのキューをリッスンしていない可能性があります。だから私は何も聞いていないならば、メッセージはちょうど落とされるだろう、私は交換b/cを使用しない理由です。メッセージが処理されるまでQueue60にとどまるようにメッセージが必要です。

マスター2がオンラインになると、そのデバイスが処理する600個のデバイスのリストが表示されます。だから、その時点でバインディングを作成することができます。

「Device60」のメッセージを「Master2」キューに配信するために、キューからキューへのバインディングを実行するにはどうすればよいですか。

私は、これがすべて間違っ

要件は、任意のデバイスがメッセージ（複数可）に送信することができますし、彼らが、保存されている私はAMQPのRabbitMQの実装に基づいて「正しい」方法を理解する助けてください近づいていた場合

Answer 1

Exchangeを作成し、交換にバインドされたDevice60というキューを使用して、ルーティングキーを使用することができます。

channel.queueBind("Device60","myexchange","device.60") 

この時点で、ルーティングキーを使用してメッセージを公開できます。たとえば ：

channel.basicPublish("myexchange","device.60",mymessage); 

今Device60がメッセージを受信し、消費者がオンラインになるまで、それらを格納します。他のデバイスについては

それは同じです：

channel.queueBind("Device50","myexchange","device.50") 

と

channel.basicPublish("myexchange","device.50",mymessage); 

私はそれが役に立てば幸い。