2016-11-15 72 views
1

我想通過akka和scala監控我們的訂單流程,並且想要構建一個actor系統。 來自網上商店的消息存儲在mongoDB中,並存儲在4個不同的集合中。 每個集合都需要一個自己的FSM,因爲這個訂單在每個集合中都有不同的狀態(例如collection1 = payment,collection2 = delivery,...)如何每X分鐘查詢一次數據庫

我的問題是如何設置這個整個actor系統。 特別是我需要知道我如何處理mongoDB,因爲我需要查看數據庫中每隔X分鐘是否有新條目。這個查詢應該由一個Actor執行,它將消息發送給FSM。我怎樣才能做到這一點?

我真的沒有找到谷歌的東西(或者我只是不知道該怎麼谷歌:/)

感謝提前:)

回答