scala - akka cluster seed nodes give error: dropping message for non-local recipient -


i'm trying create basic akka cluster on win 7 machine documentation:
http://doc.akka.io/docs/akka/snapshot/scala/cluster-usage.html

and i'm getting error when run seed nodes (more on them below)

adriansclustersystem-akka.actor.default-dispa tcher-16] [akka://adriansclustersystem/system/endpointmanager/reliableendpointwr iter-akka.tcp%3a%2f%2fadriansclustersystem%40127.0.0.1%3a2552-3/endpointwriter] dropping message [class akka.actor.selectchildname] non-local recipient [act or[akka.tcp://clustersystem@127.0.0.1:2552/]] arriving @ [akka.tcp://clustersys tem@127.0.0.1:2552] inbound addresses [akka.tcp://adriansclustersystem@127.0 .0.1:2552]

question: why getting error? did miss akka documentation?

my .conf file:
added line *to file listed @ url above * enabled-transports = ["akka.remote.netty.tcp"]

akka {   actor {     provider = "akka.cluster.clusteractorrefprovider"   }   remote {     enabled-transports = ["akka.remote.netty.tcp"]  <--added remoting     log-remote-lifecycle-events = off     netty.tcp {       hostname = "127.0.0.1"       port = 0     }   }   cluster {     seed-nodes = [     "akka.tcp://clustersystem@127.0.0.1:2551",     "akka.tcp://clustersystem@127.0.0.1:2552"]    auto-down = on   } } 

i start 2 nodes, each in different sbt windows

run-main sample.cluster.simple.simpleclusterapp 2551   run-main sample.cluster.simple.simpleclusterapp 2552 

both of these start fine repeatedly show error message:

mybuild:-:0.0.1-snapshot>`run-main sample.cluster.simple.simpleclusterapp 2552` [warn] credentials file c:\users\amocanu\.ivy2\.credentials not exist  <-- ? [info] running sample.cluster.simple.simpleclusterapp 2552  args[0]= 2552 [info] [07/31/2013 10:50:00.397] [run-main] [remoting] starting remoting [info] [07/31/2013 10:50:00.661] [run-main] [remoting] remoting started; listeni ng on addresses :[akka.tcp://adriansclustersystem@127.0.0.1:2552] [info] [07/31/2013 10:50:00.710] [run-main] [cluster(akka://adriansclustersystem )] cluster node [akka.tcp://adriansclustersystem@127.0.0.1:2552] - starting up.. . [info] [07/31/2013 10:50:00.823] [run-main] [cluster(akka://adriansclustersystem )] cluster node [akka.tcp://adriansclustersystem@127.0.0.1:2552] - registered cl uster jmx mbean [akka:type=cluster] [info] [07/31/2013 10:50:00.823] [run-main] [cluster(akka://adriansclustersystem )] cluster node [akka.tcp://adriansclustersystem@127.0.0.1:2552] - started su ccessfully [info] [07/31/2013 10:50:00.868] [adriansclustersystem-akka.actor.default-dispat cher-2] [cluster(akka://adriansclustersystem)] cluster node [akka.tcp://adriansc lustersystem@127.0.0.1:2552] - metrics retreived mbeans, , may  incorrect on platforms. increase metric accuracy add 'sigar.jar'  classpath , appropriate platform-specific native libary 'java.libr ary.path'. reason: java.lang.classnotfoundexception: org.hyperic.sigar.sigar [info] [07/31/2013 10:50:00.874] [adriansclustersystem-akka.actor.default-dispat cher-2] [cluster(akka://adriansclustersystem)] cluster node [akka.tcp://adriansc lustersystem@127.0.0.1:2552] - metrics collection has started [info] [07/31/2013 10:50:00.883] [adriansclustersystem-akka.actor.default-dispat cher-13] [akka://adriansclustersystem/user/clusterlistener] current members: [error] [07/31/2013 10:50:01.003] [adriansclustersystem-akka.actor.default-dispa tcher-3] [akka://adriansclustersystem/system/endpointmanager/reliableendpointwri ter-akka.tcp%3a%2f%2fadriansclustersystem%40127.0.0.1%3a2551-0/endpointwriter] d ropping message [class akka.actor.selectchildname] non-local recipient [acto r[akka.tcp://clustersystem@127.0.0.1:2552/]] arriving @ [akka.tcp://clustersyst em@127.0.0.1:2552] inbound addresses [akka.tcp://adriansclustersystem@127.0. 0.1:2552] [error] [07/31/2013 10:50:01.009] [adriansclustersystem-akka.actor.default-dispa tcher-16] [akka://adriansclustersystem/system/endpointmanager/reliableendpointwr iter-akka.tcp%3a%2f%2fadriansclustersystem%40127.0.0.1%3a2552-3/endpointwriter] dropping message [class akka.actor.selectchildname] non-local recipient [act or[akka.tcp://clustersystem@127.0.0.1:2552/]] arriving @ [akka.tcp://clustersys tem@127.0.0.1:2552] inbound addresses [akka.tcp://adriansclustersystem@127.0 .0.1:2552] 

if

run-main sample.cluster.simple.simpleclusterapp 

which supposed choose random port , run seed node on, starts of other 2 seed nodes, shows class not found exception info , no current members

[info] [07/31/2013 11:19:36.612] [adriansclustersystem-akka.actor.default-dispat cher-3] [cluster(akka://adriansclustersystem)] cluster node [akka.tcp://adriansc lustersystem@127.0.0.1:54824] - metrics retreived mbeans, , may b e incorrect on platforms. increase metric accuracy add 'sigar.jar' t o classpath , appropriate platform-specific native libary 'java.lib rary.path'. reason: java.lang.classnotfoundexception: org.hyperic.sigar.sigar [info] [07/31/2013 11:19:36.619] [adriansclustersystem-akka.actor.default-dispat cher-3] [cluster(akka://adriansclustersystem)] cluster node [akka.tcp://adriansc lustersystem@127.0.0.1:54824] - metrics collection has started [info] [07/31/2013 11:19:36.633] [adriansclustersystem-akka.actor.default-dispat cher-12] [akka://adriansclustersystem/user/clusterlistener] current members: 

yup hangs there , have close sbt window terminate it.

it looks seed nodes using clustersystem actor system name according logs using adriansclustersystem actor system name. try changing seed nodes to:

seed-nodes = [ "akka.tcp://adriansclustersystem@127.0.0.1:2551", "akka.tcp://adriansclustersystem@127.0.0.1:2552"] 

Comments

Popular posts from this blog

c++ - Creating new partition disk winapi -

Android Prevent Bluetooth Pairing Dialog -

VBA function to include CDATA -