Hello all,
I'm getting a hard time trying to get the samples
at http://doc.akka.io/docs/akka/snapshot/contrib/distributed-pub-sub.html
to work.
I've implemented the Subscriber and the Publisher as described in the
article and created 2 systems with the following configurations:
*seed ActorSystem (where Publisher is registered):*
*akka {*
* extensions = ["akka.contrib.pattern.DistributedPubSubExtension"]*
* actor {*
* provider = "akka.cluster.ClusterActorRefProvider"*
* }*
* remote {*
* log-remote-lifecycle-events = on*
* netty.tcp {*
* hostname = "127.0.0.1"*
* port = 2551*
* }*
* }*
* cluster {*
* seed-nodes = ["akka.tcp://ClusterSystem@127.0.0.1:2551"]*
* auto-down-unreachable-after = 10s*
* }*
*}*
*worker ActorSystem (where Subscriber is registered):*
*akka {*
* extensions = ["akka.contrib.pattern.DistributedPubSubExtension"]*
* actor {*
* provider = "akka.cluster.ClusterActorRefProvider"*
* }*
* remote {*
* log-remote-lifecycle-events = on*
* netty.tcp {*
* hostname = "127.0.0.1"*
* port = 0*
* }*
* }*
* cluster {*
* seed-nodes = ["akka.tcp://ClusterSystem@127.0.0.1:2551"]*
* auto-down-unreachable-after = 10s*
* }*
*}*
But after sending "hello world" to Publisher nothing is printed. Here
is the full log:
*[INFO] [01/22/2015 20:43:59.631] [main] [Remoting] Starting remoting*
*[INFO] [01/22/2015 20:43:59.771] [main] [Remoting] Remoting started;
listening on addresses :[akka.tcp://ClusterSystem@127.0.0.1:2551]*
*[INFO] [01/22/2015 20:43:59.772] [main] [Remoting] Remoting now listens on
addresses: [akka.tcp://ClusterSystem@127.0.0.1:2551]*
*[INFO] [01/22/2015 20:43:59.782] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Starting up...*
*[INFO] [01/22/2015 20:43:59.847] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Registered cluster
JMX MBean [akka:type=Cluster]*
*[INFO] [01/22/2015 20:43:59.847] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Started up
successfully*
*[INFO] [01/22/2015 20:43:59.850]
[ClusterSystem-akka.actor.default-dispatcher-4]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] - Metrics will be retreived from
MBeans, and may be incorrect on some platforms. To increase metric accuracy
add the 'sigar.jar' to the classpath and the appropriate platform-specific
native libary to 'java.library.path'. Reason:
java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar*
*[INFO] [01/22/2015 20:43:59.851]
[ClusterSystem-akka.actor.default-dispatcher-4]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] - Metrics collection has started
successfully*
*[INFO] [01/22/2015 20:43:59.859]
[ClusterSystem-akka.actor.default-dispatcher-14]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] - Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] is JOINING, roles []*
*[INFO] [01/22/2015 20:43:59.881] [main] [Remoting] Starting remoting*
*[INFO] [01/22/2015 20:43:59.888] [main] [Remoting] Remoting started;
listening on addresses :[akka.tcp://ClusterSystem@127.0.0.1:54670]*
*[INFO] [01/22/2015 20:43:59.888] [main] [Remoting] Remoting now listens on
addresses: [akka.tcp://ClusterSystem@127.0.0.1:54670]*
*[INFO] [01/22/2015 20:43:59.889] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:54670] - Starting up...*
*[INFO] [01/22/2015 20:43:59.891] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:54670] - Started up
successfully*
*[INFO] [01/22/2015 20:43:59.892]
[ClusterSystem-akka.actor.default-dispatcher-4]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:54670] - Metrics will be retreived from
MBeans, and may be incorrect on some platforms. To increase metric accuracy
add the 'sigar.jar' to the classpath and the appropriate platform-specific
native libary to 'java.library.path'. Reason:
java.lang.ClassNotFoundException: org.hyperic.sigar.Sigar*
*[INFO] [01/22/2015 20:43:59.892]
[ClusterSystem-akka.actor.default-dispatcher-4]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:54670] - Metrics collection has started
successfully*
*[INFO] [01/22/2015 20:43:59.904]
[ClusterSystem-akka.actor.default-dispatcher-2]
[akka://ClusterSystem/user/subscriber1] subscribing*
*[INFO] [01/22/2015 20:44:00.048]
[ClusterSystem-akka.actor.default-dispatcher-2]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] - Node
[akka.tcp://ClusterSystem@127.0.0.1:54670] is JOINING, roles []*
*[INFO] [01/22/2015 20:44:00.165]
[ClusterSystem-akka.actor.default-dispatcher-14]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:54670] - Welcome from
[akka.tcp://ClusterSystem@127.0.0.1:2551]*
*[INFO] [01/22/2015 20:44:00.867]
[ClusterSystem-akka.actor.default-dispatcher-14]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] - Leader is moving node
[akka.tcp://ClusterSystem@127.0.0.1:2551] to [Up]*
*[INFO] [01/22/2015 20:44:00.868]
[ClusterSystem-akka.actor.default-dispatcher-14]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://ClusterSystem@127.0.0.1:2551] - Leader is moving node
[akka.tcp://ClusterSystem@127.0.0.1:54670] to [Up]*
What am I missing? Is there a working sample for this extension?
Best regards,
Thiago Souza
--
>>>>>>>>>> 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.
