进行无限循环。
我想通过akka和scala监控我们的订单流程，并想构建一个演员系统。来自网店的消息存储在mongoDB中，并存储在4个不同的集合中。每个集合需要一个自己的FSM，因为订单在每个集合中有不同的状态(例如，collection1=payment, collection2=delivery，…)
我的问题是如何建立整个演员系统。特别是我需要知道我如何处理mongoDB，因为我需要看看每隔X分钟数据库中是否有新条目。该查询应该由Actor执行，Actor将其消息发送给FSMs。我怎样才能做到呢?
我真的没有在谷歌上找到什么(或者我只是不知道谷歌什么:/)
提前感谢:)
akka有一个调度程序。您可以使用它每X次执行一次查询:http://doc.akka.io/docs/akka/current/scala/scheduler.html
另一种(丑陋的)解决方案是使用线程睡眠