Hello Jeff, Basically I want to pile a bunch of messages into this mailbox and have the > actor process them when it "can" with a producer timeout restriction. I > know this is related to the Reactive Stream stuff, but I'm interested in > something near term and deciding if I should implement a DurableMailbox or > spend more time trying to bend Persistence to work with my stateless > actor. > When reading your description I was about to answer “reactive streams”, but I see you’re well aware already :-)
Have you seen this thread: [akka-user] Pulling pattern vs. Durable Mailboxes <https://groups.google.com/forum/#!msg/akka-user/RrnK9rT6Qw4/FuVRm22MvakJ>? One thing you could do is to introduce an intermediate actor, which will handle the persisting, and your worker actor would pull the work from this PersistentActor. The persistentActor can then deleteMessages(toSequenceNr: Long) once it gets a confirmation that the worker processed messages until N. -- Cheers, Konrad 'ktoso' Malawski hAkker @ Typesafe <http://typesafe.com> -- >>>>>>>>>> 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.
