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://[email protected]: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://[email protected]: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://[email protected]:2551]*
*[INFO] [01/22/2015 20:43:59.772] [main] [Remoting] Remoting now listens on
addresses: [akka.tcp://[email protected]:2551]*
*[INFO] [01/22/2015 20:43:59.782] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://[email protected]:2551] - Starting up...*
*[INFO] [01/22/2015 20:43:59.847] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://[email protected]:2551] - Registered cluster
JMX MBean [akka:type=Cluster]*
*[INFO] [01/22/2015 20:43:59.847] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]:2551] - Node
[akka.tcp://[email protected]: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://[email protected]:54670]*
*[INFO] [01/22/2015 20:43:59.888] [main] [Remoting] Remoting now listens on
addresses: [akka.tcp://[email protected]:54670]*
*[INFO] [01/22/2015 20:43:59.889] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://[email protected]:54670] - Starting up...*
*[INFO] [01/22/2015 20:43:59.891] [main] [Cluster(akka://ClusterSystem)]
Cluster Node [akka.tcp://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]:2551] - Node
[akka.tcp://[email protected]: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://[email protected]:54670] - Welcome from
[akka.tcp://[email protected]:2551]*
*[INFO] [01/22/2015 20:44:00.867]
[ClusterSystem-akka.actor.default-dispatcher-14]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2551] - Leader is moving node
[akka.tcp://[email protected]:2551] to [Up]*
*[INFO] [01/22/2015 20:44:00.868]
[ClusterSystem-akka.actor.default-dispatcher-14]
[Cluster(akka://ClusterSystem)] Cluster Node
[akka.tcp://[email protected]:2551] - Leader is moving node
[akka.tcp://[email protected]: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 [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/d/optout.
