What about doing it on the read side, that could consume all tagged events. It could keep track of latest event time for each persistenceId and alert if deadline exceeded.
/Patrik lör 11 nov. 2017 kl. 16:52 skrev lutzh <[email protected]>: > Hi mailing list, > > I was wondering if anyone had some good ideas about this. Say I have an > actor that receives data from some sensor, once an hour. I'm using Akka > Cluster Sharding and Akka Persistence. So the message arrives, Akka will > take care of restoring the actor state, processing the message etc. After a > couple of minutes, the actor will be passivated. > > Now it may happen that the sensor sending the data breaks, and no more > messages are received. I would like my actor to detect this, i.e. I would > like to implement some sort of timeout or scheduled message that activates > the actor, so it can detect it has not received messages for a long time > and issue some sort of alert. > > I've seen/built solutions where all entity IDs where stored, or all > persistence IDs where retrieved with PersistenceQuery, and then all actors > would be notified and "woken up" and could check their state. That seems > somewhat inefficient to me. Maybe people have better ideas how to achieve > this "self-check" than in this "global" manner? > > I think there might be a way to get the currently active actors from the > shard region via GetCurrentShardState, but that would only give me the > currently active / in memory ids, I believe. Are the ids of passivated > actors stored in memory somewhere, and accessible? Or any other ideas how > to approach this in a distributed fashion? > > Thanks for your help, > Lutz > > > -- > >>>>>>>>>> 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. > -- >>>>>>>>>> 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.
