【发布时间】：2017-03-29 02:07:44
【问题描述】：
我想通过 akka 和 scala 监控我们的订单流程，并想构建一个 Actor 系统。 来自网上商店的消息存储在 mongoDB 中，并存储在 4 个不同的集合中。 每个集合都需要一个自己的 FSM，因为订单在每个集合中都有不同的状态（例如 collection1=payment，collection2=delivery，...）
我的问题是如何设置整个演员系统。 特别是我需要知道如何处理 mongoDB，因为我需要每隔 X 分钟查看数据库中是否有新条目。此查询应由 Actor 执行，该 Actor 将其消息发送到 FSM。我怎样才能做到这一点？
我并没有真正在 Google 上找到任何东西（或者我只是不知道用 Google 搜索什么：/）
提前致谢:)
【问题讨论】：
标签： mongodb scala akka actor fsm