I modified typesafe's activator-akka-cluster-sharding-scala exampl <https://github.com/typesafehub/activator-akka-cluster-sharding-scala>e:
https://gist.github.com/jgrowl/028e621d32f2388e876a Basically I have a Publisher node which has an accompanying redis node that watches for messages and then will send it to the publisher. Likewise there is a Subscriber that also has a redis watcher. My code can send messages to my publisherRegion but messages sent to subscriberRegion never reach the intended target. I never get any errors, the messages just go in silently. What seems to be happening is that messages are going into the shardBuffers but a receiveCoordinatorMessage is never sent so the messages stay there forever. If I comment out the publisher node and run the subscriber node (with its redis node) then the subscriber works fine in isolation. When using them together though only one will receive messages. I am not sure if what I am trying to do is just outside of the realm of expected use cases, if there is a bug somewhere, or if I am just doing something wrong. Any ideas? Thanks, Jon -- >>>>>>>>>> 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.
