I am a newbie to the akka framework. I would like to understand how to
compile and run akka -samples in Distributed Data as I am working on a
project related toeventual consistency. It would be really helpful if
someone could guide me in the right direction as to how to run these
samples. I dow
Hello,
I have API response coming as a JSON string where Server won't support
chunked response. I'm using below sample code to parse the JSON using *Jackson
parser*.
type Result = Map[String, List[(String, JValue)]]
private def apiResult(resp : HttpResponse): Future[Result] = {
Unmarshal(res
Has anyone implemented a PersistentFSM based actor with at-least-once
messaging?
How did you deal with duplicates and out-of-order messaging using the
Stash? I would seem that you'd need to override processMsg in the
PersistentFSMBase class to handle out-of-order events to get ahead of the
FS