RabbitMQ - 別のコンシューマにデータを送信する

Question

私はRabbitMQを使用する新生児です。私は消費者から別のものにデータを送ることが可能かどうかを知りたい。

は、私は、パイプクラスの実行に自分のアプリケーションにPipeline patternを実装したい、

を説明しましょう。

例：私は何をしたいか

// payload = 20 (at the entrance) 
$pipeline = (new Pipeline) 
    ->pipe(function ($payload) { 
     return $payload * 10; 
    }) 
    ->pipe(function ($payload) { 
     return $payload + 10; 
    }) 
    ->pipe(function ($payload) { 
     return $payload - 5; 
    }) 
; 
// payload = 205 (at the end) 

は、それがように別の消費者に計算されたデータを送信し終えたときに、消費者の最初のコールバックを実行することです。最終的に$payloadの値として205があるようにする。

私はRabbitMQでそれを行うことが可能かどうかを知りたいですか？

は、ご返答をたくさんありがとうございました:)もちろんの

Answer 1

はい。 1つのrabbitmqクライアントは、同時に消費者と出版者になり、それぞれの「機能」は2つの独立したスレッドになり、それぞれは独自のチャネルを使用します。

メッセージを（特定の方法で）バインドされたキューにルーティングするエクスチェンジに直接送信するのではなく、消費者に直接メッセージを送信することはありません。消費者は自分自身をキューに「添付」して消費する。