On Wed, Nov 9, 2016 at 1:59 PM, Ricardo Gasca <[email protected]> wrote:
> I'm working in the following scenario: > > > - Cluster Akka with several nodes. Each node has: > - several publishers that share a part of whole information in the > system. Like a shard. > - several subscriber that works with the whole information in the > system. > - When a subscriber start up, subscribes to the topic, send a messages > to all publishers to recover all current information > - Every publisher send each part of information to subscriber > - When publisher detect MemberUp of other node, needs to react to send > information to subscribers of the new node. > > > When publisher actor reacts to MemberUp message, > the DistributedPubSubMediator is not ready to publish information to new > node because, I think, Mediator has not yet proccessed the MemberUp message. > Yes, that can be the case, and it can also be that the actual topic subscription has not been propagated from the new subscriber node to the publisher node yet. > > Now, my solution is that publisher react with a timeout to MemberUp > message in order to Mediator can proccess the same MemberUp message. > > > does DistributedPubSubMediator provide a callback method to react when it > has proccessed MemberUp message? > no, there is no such notification The only way to know that it is received is to send back and acknowledgment. That is difficult to manage for each message in a full pub-sub mesh, but perhaps you can do it for some initial message. You would retry/resend this initial message when a new MemberUp until you get an acknowledgment from that address. > > > -- > >>>>>>>>>> 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
