2016-12-12 15 views
0

いくつかの識別子を持つ複数のメッセージを受け取るキューを作成したいとします。私はこのキューを非同期的に処理したいが、消費者が識別子xでメッセージを処理している場合、同じ識別子を持つ他のメッセージは他のコンシューマーに公開することはできない。消費者がそのメッセージで処理されると、それを報告し、その識別子を持つメッセージを再度発行することができます。RabbitMQを使用して単一のキューで複数のコンシューマとの並行性を管理する方法は?

基本的に、キューは複数のチャネルに分岐し、各チャネルは識別子を表し、それらのチャネルのメッセージは到着時間によってソートされ、チャネルの各メッセージは同期的に処理されますが、非同期にキューに入れられます。

これは可能ですか?

答えて

0

これは可能ですか?

RabbitMQには直接接続できません。

私は私のシステムの1つに似た要件を持っており、メッセージプロデューサのために私のコードでそれをすべて処理しました。

関連する問題