0

我正在使用application.conf中的路由器配置创建路由器。

在某种情况下,我需要手动删除路由并将路由添加到我的路由器。我在 akka-scala 文档(链接)中看到,使用removeRouteeandRoutee我们将能够实现它。

但由于我使用配置创建路由器,我可以使用以下代码选择路由器。

var router = Akka.system().actorSelection("/user/intelliSupervisor/router")
    var routerFut = router.resolveOne()(10)

    routerFut.onComplete {
      case Success(actor) => {
        // 'actor' RoutedActorRef
      }
      case Failure(ex) =>
    } 

在未来 onComplete Success 调用它返回akka.routing.RoutedActorRef。如何访问创建的akka.routing.Router?或者无论如何我可以将它转换为路由器对象?

非常感谢您提前。

4

0 回答 0