私は、連続して実行する必要のあるコマンドのパイプラインを持ち、コマンドの中には並列(同じ相関ID)で実行する必要がある複数の操作が含まれているとします。パイプラインでさらに実行を進めるために、すべての並列操作がいつ実行されるのかを知る必要があると仮定しましょう。RabbitMqメッセージを相関IDで1つのメッセージに集約する方法
データベースのような外部データソースを使用せずに交換とキューを使用することで、RabbitMQだけでこの種のオーケストレーションを実現できますか?
私は次のユースケースに興味があります: 同じキューの3つのメッセージを同じキューに公開しました。これらのメッセージは並行して処理されています。同じ相関IDのすべてのメッセージが正常に終了した場合にのみ、新しいメッセージを公開したいと思います。
これをRabbitMQで実現する方法はありますか?