Hi Thiago, have you seen the activator template "Akka Clustered PubSub with Scala!" <http://doc.akka.io/docs/akka/snapshot/contrib/distributed-pub-sub.html> which is linked from that documentation page?
On Fri, Jan 23, 2015 at 12:52 AM, Thiago Souza <[email protected]> wrote: > 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 > <http://[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 > <http://[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 > <http://[email protected]:2551>]* > *[INFO] [01/22/2015 20:43:59.772] [main] [Remoting] Remoting now listens > on addresses: [akka.tcp://[email protected]:2551 > <http://[email protected]:2551>]* > *[INFO] [01/22/2015 20:43:59.782] [main] [Cluster(akka://ClusterSystem)] > Cluster Node [akka.tcp://[email protected]:2551 > <http://[email protected]:2551>] - Starting up...* > *[INFO] [01/22/2015 20:43:59.847] [main] [Cluster(akka://ClusterSystem)] > Cluster Node [akka.tcp://[email protected]:2551 > <http://[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 > <http://[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 > <http://[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 > <http://[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 > <http://[email protected]:2551>] - Node > [akka.tcp://[email protected]:2551 > <http://[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 > <http://[email protected]:54670>]* > *[INFO] [01/22/2015 20:43:59.888] [main] [Remoting] Remoting now listens > on addresses: [akka.tcp://[email protected]:54670 > <http://[email protected]:54670>]* > *[INFO] [01/22/2015 20:43:59.889] [main] [Cluster(akka://ClusterSystem)] > Cluster Node [akka.tcp://[email protected]:54670 > <http://[email protected]:54670>] - Starting up...* > *[INFO] [01/22/2015 20:43:59.891] [main] [Cluster(akka://ClusterSystem)] > Cluster Node [akka.tcp://[email protected]:54670 > <http://[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 > <http://[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 > <http://[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 > <http://[email protected]:2551>] - Node > [akka.tcp://[email protected]:54670 > <http://[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 > <http://[email protected]:54670>] - Welcome from > [akka.tcp://[email protected]:2551 > <http://[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 > <http://[email protected]:2551>] - Leader is moving node > [akka.tcp://[email protected]:2551 > <http://[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 > <http://[email protected]:2551>] - Leader is moving node > [akka.tcp://[email protected]:54670 > <http://[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. > -- Martynas Mickevičius Typesafe <http://typesafe.com/> – Reactive <http://www.reactivemanifesto.org/> Apps on the JVM -- >>>>>>>>>> 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.
