問題タブ [axon]

Allard ( https://github.com/abuijze/bootiful-axon ) が共有する axon-springboot の例に従っています。

これまでの私の理解は次のとおりです:(概念の一部を誤解している場合は修正してください)

イベントは発生し、イベント ストア/イベント バス (Mysql) に格納されます (EmbeddedEventStore を使用)。これで、イベント プロセッサ (私の場合は TrackingProcessors) がソース (MySql - ですよね?) からイベントを取得し、イベント ハンドラがビジネス ロジックを実行して、RabbitMQ に発行されたクエリ ストレージとメッセージを更新します。

最初の質問は、いつ、どこで、誰がこのメッセージを RabbitMQ に発行するかです (メッセージ リスナーが構成されている統計アプリケーションで使用されます)。

リプレイ機能を試すように TrackingProcessor を構成しました。リプレイを実行するには、プロセッサを停止し、プロセッサのトークン エントリを削除します。プロセッサを起動すると、イベントがリプレイされ、クエリ ストレージが予想どおり最新の状態になります。

2 番目の質問は、リプレイがトリガーされてクエリ ストレージが更新されたときに、RabbitMQ にパブリッシュされているメッセージが表示されないことです...そのため、統計アプリケーションが同期していません。私は何か間違ったことをしていますか？

あなたがアドバイスしていただけますか？ありがとうシン

私は axon 3.1.1 を使用しています。イベントを mongodb に
保存しているときに、XML 形式で保存できます。
しかし、Jacksonシリアライザーを使用してJSON形式に変換している間、ストレージ戦略を取得できません。

私がやっていることは ここ に
あり ます }

また、ストレージ戦略が不要で、このデフォルトを維持する場合はどうすればよいかを共有してください

前もって感謝します