*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].
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.
