我正在使用application.conf中的路由器配置创建路由器。
在某种情况下,我需要手动删除路由并将路由添加到我的路由器。我在 akka-scala 文档(链接)中看到,使用removeRoutee和andRoutee我们将能够实现它。
但由于我使用配置创建路由器,我可以使用以下代码选择路由器。
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?或者无论如何我可以将它转换为路由器对象?
非常感谢您提前。