2017-07-04 1 views
0

私はフレームワークAxon 3で構築されたアプリケーションを持っています。Axon 3でRabbitMQでイベントを再生することは可能ですか

  • 2つのインスタンス(JVM)
  • は、最初のものは、コマンドを処理し、リードモデルデータベースを構築するためのRabbitMQと二番目に通知があります。
  • あり、このアプリケーションのイベント・ストア(MongoDBの)

は、今私は3番目のインスタンスを構築したいですし、可能性の初期状態を構築するためのRabbitMQを経由して最初のインスタンスのすべての歴史的なイベントを再生するということです3番目のインスタンス?どのように設定するのですか?

私は答えをthe doc Axonsを試してみました、私が代わりにデフォルトのSubscribingEventProcessorTrackingEventProcessorを使用する必要があるようですが、それは(DOCで述べた)SpringAMQPMessageSourceで使用することはできません

答えて

0

アクソンの2つのモードがあります:トラッキングおよび購読。あなたのイベントのソースに応じて、どちらか一方、あるいは両方のスタイルを選択することができます。

AMQPはメッセージブローカーの仕様です。メッセージが配信されると、メッセージはそのメッセージが配置されたキューから削除されます。したがって、概念的には、ブローカーには存在しないため、これらのイベントを再生することは不可能です。

リプレイが重要な場合は、メッセージを格納するメッセージングメカニズムを使用していることを確認してください。 Axonでは、EventStoreはまさにこれを行います。今のところ、AxonにはEmbeddedEventStoreしかありませんが、受信ノードのイベントストアに送信ノードと同じデータベースを指定させることができます。

現時点では、AxonIQでは、これをより洗練された方法で処理する(イベント間でデータソースを共有する必要はありません)イベントストアサーバーに取り組んでいます。

+0

ありがとうございます。イベントストアサーバーは、私たちにとって非常に興味深いと思います。 – Lei

+0

8月にはいつかベータプログラムを公開する予定です。 axoniq.ioのニュースレターを購読すれば、ベータ版が利用可能になるとすぐに通知します。 – Allard

関連する問題