No worker listen at controller actual host address not at localhost 127.0.0.1.
On Thursday, February 13, 2014 3:40:43 AM UTC-8, rkuhn wrote: > > Your worker does not listen at 127.0.0.1. > > 12 feb 2014 kl. 01:22 skrev HARSH PATEL <[email protected] <javascript:> > >: > > *Remote Controller System:* > > Code: > private final ActorRef reaper = > getContext().actorOf(Props.create(Reaper.class), "reaper"); > private final ActorRef router = > getContext().actorOf(Props.create(Worker.class).withRouter(new > RemoteRouterConfig(new RoundRobinRouter(10), getNodes())), "router"); > > getnodes is List<Address> > > application.conf: > akka { > log-dead-letters-during-shutdown = off > actor { > provider = "akka.remote.RemoteActorRefProvider" > remote { > enabled-transports = ["akka.remote.netty.tcp"] > transport-failure-detector { > acceptable-heartbeat-pause = 100s > } > watch-failure-detector { > acceptable-heartbeat-pause = 100s > } > netty.tcp { > hostname = "127.0.0.1" > port = 2552 > } > } > } > } > > > *Remote Worker System:* > Code: > private ActorSystem system; > > public RemoteWorker(String name) { > Config conf = ConfigFactory.load("remote"); > int port = conf.getInt("akka.remote.netty.tcp.port"); > system = ActorSystem.create(name, conf); > } > > private void handleShutdown() { > Runtime.getRuntime().addShutdownHook(new Thread() { > @Override public void run() { > System.out.println("Shutting down remote actor system..."); > system.shutdown(); > } > }); > } > > public static void main(String[] args) { > String systemName = (args.length == 0) ? "remote" : args[0]; > RemoteWorker remsys = new RemoteWorker(systemName); > remsys.handleShutdown(); > } > > > remote.conf > akka { > log-dead-letters-during-shutdown = off > actor { > provider = "akka.remote.RemoteActorRefProvider" > } > remote { > enabled-transports = ["akka.remote.netty.tcp"] > netty.tcp { > hostname = "" > port = 2553 > } > } > } > > *Error:* > > [WARN] [02/11/2014 14:50:26.728] [remote-akka.actor.default-dispatcher-17] > [akka://..../system/remote-watcher] Detected unreachable: > [akka.tcp://[email protected]:2553] > [INFO] [02/11/2014 14:50:26.728] [remote-akka.actor.default-dispatcher-15] > [Remoting] Address [akka.tcp://[email protected]:2553] is now quarantined, > all messages to this address will be delivered to dead letters. > > > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: http://akka.io/faq/ > >>>>>>>>>> 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] <javascript:>. > To post to this group, send email to [email protected]<javascript:> > . > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/groups/opt_out. > > > > > *Dr. Roland Kuhn* > *Akka Tech Lead* > Typesafe <http://typesafe.com/> – Reactive apps on the JVM. > twitter: @rolandkuhn > <http://twitter.com/#!/rolandkuhn> > > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> 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/groups/opt_out.
