Hi Thiago,
I am using following config on same machine with different ports and it
works without any issues .. you might want to check if your subscriber
comes-up later when compared to publisher ie. when publisher publishes,
subscriber has not yet come-up to receive the published messages
*publisher *
akka {
loglevel = "INFO"
actor {
provider = "akka.cluster.ClusterActorRefProvider"
}
remote {
log-remote-lifecycle-events = on
netty.tcp {
hostname = "127.0.0.1"
port = "1551"
}
}
cluster {
seed-nodes = [
"akka.tcp://[email protected]:1551",
"akka.tcp://[email protected]:1552"]
auto-down-unreachable-after = 10s
}
}
*subscriber*
akka {
loglevel = "INFO"
actor {
provider = "akka.cluster.ClusterActorRefProvider"
}
remote {
log-remote-lifecycle-events = on
netty.tcp {
hostname = "127.0.0.1"
port = "1552"
}
}
cluster {
seed-nodes = [
"akka.tcp://[email protected]:1551",
"akka.tcp://[email protected]:1552"]
auto-down-unreachable-after = 10s
}
}
Regards
Muthu
On Friday, 23 January 2015 04:22:15 UTC+5:30, Thiago Souza 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://www.google.com/url?q=http%3A%2F%2FClusterSystem%40127.0.0.1%3A2551&sa=D&sntz=1&usg=AFQjCNFeXQNZf7So6G3N2FP8Nwn3Yt0ADA>]
>
> 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.
