私は公開エンドポイント 'P'と2人の消費者 'A'、 'B'を持っています。
'P'がメッセージ '1' '2' '3'を発行すると、消費者は '123'の順番でメッセージを消費することが予想されます。しかし実際には、消費順序はおそらく '132'、 '312'などとなります。
私は並行処理に関連する設定を構成しているが、それは
concurrency settingsマストランジットメッセージの消費順
質問動作しません:「A」が成功したメッセージを消費するまで、メッセージを取ってから「B」を防ぐことができる設定はありますか?
おかげ
返信いただきありがとうございます。私がプリフェッチを0に設定する限り、AはBが消費を完了する前にメッセージをフェッチすることができます。これは、masstransitやrabbitmqがこの種の「ブロック」をサポートしていないことを意味しますか? – Denni
キューと分散型のコンシューマは何もサポートしません。注文が本当に重要な場合は、ストリーム処理(apache kafka)を参照できます – gertjvr
メッセージ処理の順序が重要なのはなぜですか? – gertjvr