1
我想通過akka和scala監控我們的訂單流程,並且想要構建一個actor系統。 來自網上商店的消息存儲在mongoDB中,並存儲在4個不同的集合中。 每個集合都需要一個自己的FSM,因爲這個訂單在每個集合中都有不同的狀態(例如collection1 = payment,collection2 = delivery,...)如何每X分鐘查詢一次數據庫
我的問題是如何設置這個整個actor系統。 特別是我需要知道我如何處理mongoDB,因爲我需要查看數據庫中每隔X分鐘是否有新條目。這個查詢應該由一個Actor執行,它將消息發送給FSM。我怎樣才能做到這一點?
我真的沒有找到谷歌的東西(或者我只是不知道該怎麼谷歌:/)
感謝提前:)
好一個無限循環,這是一個好點:) 你知道我是怎麼可以確保自上次查詢後才能獲得添加的文檔? – Chaya93
不幸的是我沒有使用mongoDB的經驗.. – pedrorijo91