必要なデータがMongoDBスレーブにある場合、ActiveMQメッセージをどのように消費できますか？

Question

これは、ソフトウェアアーキテクチャに関するさらに多くの質問です。

私はいくつかのデータをMongoDBデータベースに入れ、ActiveMQメッセージを送信します。メッセージの消費者はMongoDBに存在するデータに依存しますが、スケーラビリティ上の理由から消費者がMongoDBデータベースのスレーブを使用する場合、メッセージがレプリカ内にあるときにのみメッセージが消費されることをどのように確認できますか？

私はプログラミング言語としてperlを使用しています。そのため、潜在的な解決策は、例のJavaコードの代わりに高レベルにすることをお勧めします。

Answer 1

のActiveMQやMongoDBのレプリケーションの間には、統合はありませんとして、あなたはこれに限定されています

1. は、キューからメッセージを覗きます。

2. 必要なデータがスレーブに存在することを確認します。

3. 存在する場合、消費する。それ以外の場合は、次のメッセージに進みます。

Answer 2

セルジオの答えに代わるものとして：

1. （POP）、キューからのメッセージを取る

2. それが必要とするデータがスレーブに存在することを確認します。

3. 存在する場合、消費する。それ以外の場合は、メッセージを再エンキューします。