Hello, I would like to ask about the docs in AsyncWriteJournal: *asyncWriteMessages:* *Calls to this method are serialized by the enclosing journal actor. If you spawn work in asynchronous tasks it is alright that they complete the futures in any order, but the actual writes for a specific persistenceId should be serialized to avoid issues such as events of a later * *write are visible to consumers (query side, or replay) before the events of an earlier write are visible. A PersistentActor will not send a new WriteMessages request before the previous one has been completed.*
1. The method provides the Seq[AtomicWrite], is it possible that this Seq contains more than one AtomicWrite per persistenceId? Eg. user invokes twice persistAll method? 2. The docs states that "but the actual writes for a specific persistenceId should be serialized to avoid issues such..." if my answer to my first question is true, does it mean that implementation of this method should firstly group AtomicWrite from messages by persistenceId and next store them in serialized order? Thanks, Maciej -- >>>>>>>>>> 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.
