MassTransit：複数のコンシューマー、別々のキュー/エンドポイント、配信されないメッセージ

Question

同じメッセージを受信するように2つのサービスが設定されています。 ConsumerA : IConsumer<IMessageA>およびConsumerB : IConsumer<IMessageA>。各サービスは固有のエンドポイントを設定します。 queue_aおよびqueue_bを入力し、そのコンシューマを登録します。私はRabbitMQでファンアウトタイプのIMessageAを交換して、queue_aとqueue_bに結びついているのを見ています。ここまでは順調ですね。

• 私は両方のサービスを実行してメッセージを公開しますが、サービスAだけがそれを取得します。
• サービスAを停止し、RabbitMQのBにメッセージを手動で公開します（サービスAはIMessageAをIRequestClient<IMessageA, IMessageAResponse>を使用してPOSTに応答して公開するWebサービスです。なぜ私は手動で投稿する必要があるのですか）期待どおりに消費します。

明確にするサービスAを停止して、メッセージがqueue_aとqueue_b両方にのRabbitMQによってルーティングされます。サービスAが実行されている場合は、メッセージはqueue_bがIMessageA交流にバインドされていると絶対にそれらを取得する必要があることを示す既存の交換のバインディングにもかかわらず、queue_bに行きます。または、管理用ウェブUIを通じてRabbitMQを調べることができる頃には、queue_bにメッセージが届いたという証拠はありません（すなわち、queue_b_errorまたはqueue_b_skippedには何も存在しません。

サービスAとBの両方にIReceiveObserverを追加しましたが、何も起動していないのはReceiveFaultまたはConsumeFaultです。

サービスAでの消費者は基本的にやっている：

は

var result = await MethodThatReturnsIMessageAResponse(messageA); 
context.Respond(result); 

なぜサービスは、サービスBへのメッセージの配信を妨害していますか？どこから見始めますか？特定enpoint（例えばキュー名）を必要と

c.Resolve<IBus>().CreateRequestClient<IToDoMessage, IToDoMessageResponse>(new Uri(QueueAddress + QueueName),TimeSpan.FromSeconds(5)); 

を：

Answer 1

問題は、私が使用して「出版」のメッセージだったということでした。代わりに、私はCreatePublishRequestClientを使用するために必要な：

ない特定のキューに、交流を通じて公開するバスを使用し、行く

c.Resolve<IBus>().CreatePublishRequestClient<IToDoMessage, IToDoMessageResponse>(TimeSpan.FromSeconds(5)); 

。 GitHub sample projectが前者を示すのに役立ちません...