akka + camel を使用して activemq からのメッセージを消費しています。メッセージを複製せずにこのコンシューマーを複数のマシンにデプロイする方法を見つけようとしています。この場合、私はトピックからのメッセージを消費しており、activemq は、さまざまな単一の独立したシステムではなく、さまざまなマシンに 1 つの akka システムがあることを認識している必要があります。
私はakkaクラスターを使用してそれを達成しようとしましたが、バックエンドのクラスターにサブスクライブするフロントエンドを使用した例は役に立ちません。私の「バックエンド」アクターはactivemqコンシューマー自体であり、activemqにクラスターにサブスクライブするように指示できないからです。
何か案は？