The full code is super messy, but all on github: https://github.com/jgrowl/livehq/tree/master/media/
On Thursday, January 29, 2015 at 4:10:12 PM UTC-5, Jonathan Rowlands wrote: > > My persistence configuration is the same as in the example: > > https://gist.github.com/jgrowl/bdbe0e2e552bbac9d11c > > I was unsure if I needed to create different configurations for each > ShardRegion. I tried various things with no luck. I know the typesafe > example uses two different ShardRegions and works just fine, but what I am > doing is a little different since I basically have 4 different nodes where > two of them start the clusterSharding in proxy mode. > > On Thursday, January 29, 2015 at 9:14:39 AM UTC-5, Martynas Mickevičius > wrote: >> >> Hi Jonathan, >> >> do you have persistence configuration >> <https://github.com/typesafehub/activator-akka-cluster-sharding-scala/blob/a3af802d7c0704b6be226ac8efe9c3af42e27765/src/main/resources/application.conf#L24-32> >> section >> in your modified sample? >> >> On Fri, Jan 23, 2015 at 9:11 PM, Jonathan Rowlands <[email protected]> >> wrote: >> >>> 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. >>> >> >> >> >> -- >> 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.
