In Akka 2.0.2 authors change a procedure to set a load balance. Example to set router:
val system = ActorSystem("HarvestSystem") val router = system.actorOf(Props[SiteTestActor].withRouter(RoundRobinRouter(nrOfInstances = testSiteWorkes))) implicit val timeout = Timeout (10 seconds) val countUrl=index.values.size val countDownUrl = new CountDownLatch(countUrl) var cnt=0 index.values.foreach(url =>{ Sys.info("HarvestActor::"+actorName,"Start site test "+cnt+": "+url.toString,4) cnt+=1 val futureTest=router ask SiteTestRequest(url.toString,testKeyWord,countDownUrl) |
Możliwość komentowania jest wyłączona.