The router doesn't get started automagically, you need to create it using actorOf.
Heiko On Thu, May 15, 2014 at 5:09 AM, Eugene Dzhurinsky <[email protected]>wrote: > Hello! > > I'm trying to start 2 nodes in a cluster - one with role "http" and > another one with role "chunk" role. Initially there are no actors running > at the "http" node (ones should be deployed when node "chunk" joins the > cluster) > > my application.conf: > > akka { > actor { > provider = "akka.cluster.ClusterActorRefProvider" > deployment { > /my_service/router_httpworker { > router = consistent-hashing-pool > nr-of-instances = 10 > routees.paths = ["/user/httpworker"] > cluster { > enabled = on > max-nr-of-instances-per-node = 5 > allow-local-routees = on > } > } > } > } > remote { > log-remote-lifecycle-events = off > netty.tcp { > hostname = "127.0.0.1" > port = 0 > } > } > > cluster { > seed-nodes = [ > "akka.tcp://[email protected]:2551"] > auto-down-unreachable-after = 10s > } > > extensions = ["akka.contrib.pattern.ClusterReceptionistExtension"] > > loggers = ["akka.event.slf4j.Slf4jLogger"] > loglevel = "DEBUG" > > } > > the code HTTP worker service: > > object Http { > > def main(args: Array[String]) { > val config = > ConfigFactory.parseString(s"akka.remote.netty.tcp.port=0"). > withFallback(ConfigFactory.parseString("akka.cluster.roles = > [http]")). > withFallback(ConfigFactory.load("application")) > ActorSystem("HttpCluster", config) > } > > } > > the code for the "chunk" service: > > object Chunk { > > def main(args: Array[String]) { > val config = > ConfigFactory.parseString(s"akka.remote.netty.tcp.port=2551"). > withFallback(ConfigFactory.parseString("akka.cluster.roles = > [chunk]")). > withFallback(ConfigFactory.load("application")) > val system = ActorSystem("HttpCluster", config) > system.actorOf(Props[TaskChunkActor].withRouter(RoundRobinPool(4)), > "chunk") > val ref = system.actorOf(Props[MyRef]) > Thread.sleep(1000) > system.actorSelection("/my_service/router_httpworker").tell("123", > ref) > } > > class MyRef extends Actor { > override def receive = { > case msg ⇒ println(msg) > } > } > } > > > in the logs I can see: > > 2014-05-14 23:00:37,136 INFO [EmptyLocalActorRef] Message > [java.lang.String] from Actor[akka://HttpCluster/user/$a#-289938669] to > Actor[akka://HttpCluster/my_service/router_httpworker] was not delivered. > [1] dead letters encountered. This logging can be turned off or adjusted > with configuration settings 'akka.log-dead-letters' and > 'akka.log-dead-letters-during-shutdown'. > > So it seems that the router is not started? As far as I understood from > the tutorial, the router should be started upon cluster startup, am I wrong? > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [email protected]. > To post to this group, send email to [email protected]. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Heiko Seeberger Twitter: @hseeberger Blog: blog.heikoseeberger.name -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
