在Akka中配置嵌套路由器



我有一些嵌套的Router,它将被创建为FromConfig()。我想要的是这样的:

test {
  akka.actor.deployment {
    /worker {
      router = round-robin
      nr-of-instances = 5
      /slave {
        router = broadcast
        nr-of-instances = 4
      }
    }
  }
}

但是如果我运行这个,我得到一个异常,告诉我,[akka://test/user/worker/slave]需要外部配置,并建议application.conf.

名称是正确的,并且没有嵌套路由,它可以工作。我错过了什么?

编辑
我尝试了另一种配置方法:

test{
  akka.actor.deployment {
    /worker {
      router = round-robin
      nr-of-instances = 5
    }
    /worker/slave {
      router = broadcast
      nr-of-instances = 4
    }
  }
}

这个也不工作。我也认识到,错误的实际位置不是[akka://test/user/worker/slave],而是[akka://test/user/worker/$a/slave]。这对我来说更奇怪了。我知道,$a是一个路由,但是我如何配置它呢?

编辑2 谢谢你的快速回复。对我来说,这根本不起作用,因为我使用的是scala 2.9.2和akka 2.0。有没有办法在akka 2.0中实现类似的东西?

您可以在部署路径名称中使用通配符:/worker/*/slave

相关内容

  • 没有找到相关文章

最新更新