scala – 动态地将路由添加到路由器actor

我一直在看Resizer – 但是不能满足我的需要(我看不出如何明确地要求调整大小调整大小(添加路径),并删除它似乎你需要发送毒药给演员,然后删除).

到目前为止,我有一个路由器与ActorRef的列表,我发送AddRoutee和RemoveRoutee消息….

我的业务案例：我有一个演员从网络(通过代理)获取数据,并且需要将这些数据发送到独立的角色并行进行处理.由于收件人(DAG)的图形性质,图形可以在运行时演化,顶点/边缘被修改,因此需要添加和删除路线

必须有一个更干净的方法来做到这一点.

感谢指针.

代码示例我希望Akka处理：

class MDActor extends Actor {
  @volatile var routees = Set[ActorRef]()

  def receive = {
    case ar: AddRoutee => routees = routees + ar.actorRef
    case rr: RemoveRoutee => routees = routees - rr.actorRef
    case msg => routees.foreach(r => r forward msg)
  }
}