The sender is kept by forwarding messages to the journal and back. You cannot use that for the context, unless you include it in the event.
You must freeze the context into a stable val and close over that in the persist handler. /Patrik fre 12 jun 2015 kl. 08:38 skrev Brice Figureau <[email protected]>: > Hi, > > The PersistentActor API documentation states that it is safe to close > over actor state in a persist or persistAsync, and that sender() is the > one from the original command (which allows to reply to the incoming > command). > > I've read the code (and I won't pretend I understood it correctly), but > I don't see how sender() is kept correct. > > The reason I'm asking this question is that I have a kind of around > receive wrapper that extracts from the currently processed message some > metadata (like a request id or it's originator allowing to trace the > request flow back to it's source). > This works like this pseudo-code: > > trait RequestContextActor extends PersistentActor { > final def receiveCommand = derivedReceiveWrapper(derivedReceive) > > private var currentRequestcontext: RequestContext = > RequestContext.unknown > > implicit def request: RequestContext = currentRequestcontext > > def derivedReceive: Receive > > def derivedReceiveWrapper(wrapped: Receive): Receive = { > case x: RequestContextHolder if wrapped.isDefinedAt(x) => > currentRequestcontext = x.request > wrapped(x) > currentRequestcontext = RequestContext.unknown > case message if wrapped.isDefinedAt(message) => > currentRequestcontext = RequestContext.unknown > wrapped(message) > currentRequestcontext = RequestContext.unknown > } > } > > class MyActor extends RequestContextActor { > def derivedReceive = { > case m => { > // here request is correct > persist(Event()) { > // here request is 'unknown' > } > } > } > } > > During persist/persistAsync handlers the currentRequestcontext is at the > value "unknown", while processing the message it is set to the incoming > request. > > Any idea how I could do like sender(), and keep my request context > available during persist and persistAsync handlers? > > Thanks > -- > Brice Figureau > My Blog: http://www.masterzen.fr/ > > -- > >>>>>>>>>> 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. > -- /Patrik -- >>>>>>>>>> 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.
