Hello! I'm a bit lost now.
Given the simple setup of a cluster:
- actor *TaskSchedulerActor* has been created on a node with the role "
*scheduler*" with the router "*router_scheduler*"
- actor *TaskSchedulerActor* in it's pre-start method creates 2 instances
of the actor *TaskChunkActor* on the nodes with the role "*chunk*" using
the router "*router_chunkworker*"
- after the router "*router_scheduler"* has been created, the actor
*TaskSchedulerActor* sends a broadcast message to it's routees about a
"master registration"
- actor *TaskChunkActor* responds to actor *TaskSchedulerActor* (sender)
with a "worker registration" message.
My configuration looks like this:
akka {
actor {
provider = "akka.cluster.ClusterActorRefProvider"
deployment {
"/router_scheduler/*/router_chunkworker/*/router_httpworker" {
router = consistent-hashing-pool
nr-of-instances = 10
cluster {
enabled = on
max-nr-of-instances-per-node = 5
allow-local-routees = off
use-role = "http"
}
},
"/router_scheduler/*/router_chunkworker" {
router = consistent-hashing-pool
nr-of-instances = 3
cluster {
enabled = on
max-nr-of-instances-per-node = 1
allow-local-routees = off
use-role = "chunk"
}
}
/router_scheduler {
router = consistent-hashing-pool
nr-of-instances = 3
cluster {
enabled = on
max-nr-of-instances-per-node = 1
allow-local-routees = on
use-role = "scheduler"
}
}
}
}
remote {
log-remote-lifecycle-events = off
netty.tcp {
hostname = "127.0.0.1"
port = 0
}
}
cluster {
seed-nodes = [
"akka.tcp://HttpCluster@127.0.0.1:2551"]
auto-down-unreachable-after = 10s
}
extensions = ["akka.contrib.pattern.ClusterReceptionistExtension"]
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = "DEBUG"
}
the creation of *TaskChunkActor *actors in *TaskSchedulerActor* looks like:
context.actorOf(FromConfig.props(Props[TaskChunkActor]),
"router_chunkworker")
The output I'm getting when starting 2 processes (scheduler and chunk)
looks like:
*TaskSchedulerActor:*
2014-05-18 18:55:54,959 INFO [Slf4jLogger] Slf4jLogger started
akka://HttpCluster/user/router_scheduler
2014-05-18 18:55:55,298 DEBUG [TaskSchedulerActor] Starting actor
Actor[akka://HttpCluster/user/router_scheduler/c1#-2002751946]
2014-05-18 18:55:55,298 DEBUG [TaskSchedulerActor] Broadcasting
MasterRegistration message to
Actor[akka://HttpCluster/user/router_scheduler/c1/router_chunkworker#-926069490]
*TaskChunkActor*
2014-05-18 18:56:08,149 INFO [Slf4jLogger] Slf4jLogger started
2014-05-18 18:56:09,314 DEBUG [TaskChunkActor] Starting actor
Actor[akka://HttpCluster/remote/akka.tcp/HttpCluster@127.0.0.1:2551/user/router_scheduler/c1/router_chunkworker/c1#85758385]
2014-05-18 18:56:09,319 DEBUG [TaskChunkActor] Broadcasting
MasterRegistration message to
Actor[akka://HttpCluster/remote/akka.tcp/HttpCluster@127.0.0.1:2551/user/router_scheduler/c1/router_chunkworker/c1/router_httpworker#1247872642]
It seems that the router on *TaskSchedulerActor* doesn't know that the new
node has joined the cluster, and doesn't deploy *TaskChunkActor* onto it.
What do I miss here?
Thanks!
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
