アプリケーションを1日に1回実行したい場合、開始するときには、購読しているキューからすべてのメッセージを読み込み、何らかの処理を行い、メッセージを発行して閉じなければなりません。メッセージはNServiceBusを介して送信されました。どのように処理されたかをどのように伝えますか?私はどのようにキュー内のすべてのメッセージを処理し、キューが空であるかを知ることができません。NServiceBusと組み合わされたアプリケーションの実行予定
答えて
NSertviceBus固有のものではなく、アーキテクチャ上の問題のようです。
は、これは私がNSBでそれを解決する方法を次のとおりです。
私は私のエンドポイント(加入者)Quartz .Netを実装し、StartOfBusinessDay(毎日)を示すコマンド/メッセージを送信するジョブをスケジュールする必要があります。
私はSagaを持っていて、StartOfBusinessDayで始まり、Sagaが初期化されると、TimeOut of T +(営業時間終了までの時間)を要求します。
この佐賀はメッセージを引き続き受信し、後で処理するために集約します。
TimeOutが発生すると、集計されたすべてのメッセージを処理してProcessCompletedEventを発行して、終了日のバッチが完了したことを他のサブスクライバに通知し、その日のMarkSagaCompletedを行います。
これが役に立ちます。
これで私は動作します。 – Fellmeister
StartOfBusinessDayは、前回の営業日が終了した後、基本的に2番目のメッセージになります。サガは今日のメッセージの中にどのようにマップされますか? – Fellmeister
はい.. StartOfBusinessDayは、タイムアウト後に秒を始動するようにスケジュールすることもできます。また、ONE Sagaのみがアクティブでメッセージを受信できる状態になるため、メッセージをSagaにマップする必要はありません。 – Sarmaad
- 1. Perlでの結合と組み合わせたアンパックの実行
- 2. 組み合わされた組み合わせが固まった
- 3. Ruby:OptionParserと組み合わされた設定ファイルパーサー
- 4. ストアドプロシージャと組み合わせたEntity Frameworkクエリのサーバー側実行
- 5. 組み合わされたSVN FTPシステム?
- 6. 行の数と組み合わせ
- 7. 列車+テストデータの組み合わせとクロスバリデーションの実行R
- 8. GitHubと組み合わされた単純なLaTeXビルドとデプロイ
- 9. ggplotとggmapで作成されたchoroplethの組み合わせ
- 10. Scala 2.12 FutureとEitherの組み合わせ(バイアスされたバージョン)
- 11. タイプセーフなコードと実行時の決定を組み合わせる
- 12. serviceAutoStartProvidersをApp_Offline.htmと組み合わせて実行しますか?
- 13. 列の組み合わせの組み合わせデータフレームの行ではない
- 14. ソートされたリストをグループと組み合わせる方法
- 15. SpecFlow、Selenium、Cと組み合わされた分度器#
- 16. 組み合わされたプロトコルとホストは何ですか?
- 17. 再帰と組み合わされたメンバー
- 18. 文がランダムな行の名前と組み合わされている場合
- 19. Qt組み込みアプリケーションのリモート実行
- 20. wgetとPHPを組み合わせた
- 21. LINQグループリストと組み合わせたコレクション
- 22. Doobieと組み合わせたスカラフリーモナ
- 23. Tomcatと組み合わせたActiveMq
- 24. SO_RCVTIMEOと組み合わせたMSG_WAITALL?
- 25. @AjectWockと組み合わせた@Autowire
- 26. グリッドスプリッタと組み合わせたエクスパンダ
- 27. Matlabの行の組み合わせ?
- 28. Python itertoolsの組み合わせの組み合わせ
- 29. SpringはMVCとWebFlowを組み合わせる予定ですか?
- 30. 定数の組み合わせの数
キューが空のときにアプリケーションが終了したいのはなぜですか? –
NSBはスケジュールを維持するのか、それとも何らかの外部エンティティになるのだろうか? –
スケジュールはスケジュールされたタスクによって実行され、営業終了後1日に1回のみ実行されます。ビジネスが終了すると、タスクが実行され、キュー内のすべてのメッセージが処理された後、再び閉じられます。 – Fellmeister