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.
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?
--
>>>>>>>>>> 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.
