0

MassTransit を使用すると、メッセージに相関 ID を設定でき、同じ相関 ID を持つメッセージのみを消費できることがわかっています。

コンソール アプリケーションでこれを実行しましたが、機能しません。相関 ID が異なっていても、すべてのメッセージを取得します。実際、私の「CorrelationId」プロパティは呼び出されません。

ありがとう

4

1 に答える 1

1

このタイプのコンシューマーは、インスタンス ベースのコンシューマーとしてのみ登録できます。

x.Subscribe(s => s.Instance(consumer));

また、インスタンスには CorrelationId の固定 Guid が必要です。

これは非常に早い段階で MT に組み込まれたものであり、endpoint.SendRequest() 機能が要求/応答に適しているため、実際にはあまり役に立ちません。コンテンツベースのルーティングでは、ディストリビューターの方が適しています。

于 2013-07-02T03:39:38.777 に答える