Re: [akka-user] Better way to use CompletableFuture in an Actor

You are right, I use java. Following your instruction, I have done it well. Thanks! Guofeng On Sun, Apr 24, 2016 at 11:51 PM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > I'm assuming you're using Java, please tell about this explicitly when > asking questions :-) > >

Re: [akka-user] akka persistence actor and memory issue

Patrik, Got it. Thank you! Yan On Friday, April 22, 2016 at 10:44:27 AM UTC-5, Patrik Nordwall wrote: > > No, each persistent actor will only replay its own events. The > persistenceId is part of the key in the cassandra table. > fre 22 apr. 2016 kl. 16:53 skrev Yan Pei : >

[akka-user] snapshot's sequence_nr is 0 for first time running

Got another issue. The logic is very simple: after sending certain number of messages, take a snapshot. But the sequence_nr is always 0 for the first time run. The second time, I saw some positive numbers in sequce_nr but the number is not what I am expecting. persistence_id

[akka-user] Re: from akka.persistence.journal.ReplayFilter Invalid replayed event [1] in buffer from old writer

problem due to error in naming of persistenceIds leading to 2 persistors with same id On Monday, April 25, 2016 at 11:34:21 AM UTC+1, Tim Pigden wrote: > > Hi > I'm getting this message. I'm probably doing something wrong but any idea > what that might be? I know what messages I'm persisting

[akka-user] Is it possible to put a cluster singleton on a custom dispatcher?

If I wanted to declare a PinnedDispatcher for use by a singleton, can I do it? I've tried declaring such a dispatcher in the .conf, and then in an akka.deploy section naming the path of the singleton to use that dispatcher. Either I'm not doing it correctly, or it's being ignored. It still

Re: [akka-user] akka-http, response with "application/json" media type

Thanks for your response! Is it possible to combine it with play-json? My spray function I'm trying to rewrite looks like def jsonRoute(fn: => ToResponseMarshallable, method: Directive0 = get): Route = method { val jsonResponse = respondWithMediaType(`application/json`) {

[akka-user] from akka.persistence.journal.ReplayFilter Invalid replayed event [1] in buffer from old writer

Hi I'm getting this message. I'm probably doing something wrong but any idea what that might be? I know what messages I'm persisting and this particular test is one in which I kill off my persistor and restart it. Or does it indicate the message is failing to deserialize or something like that

Re: [akka-user] Re: from akka.persistence.journal.ReplayFilter Invalid replayed event [1] in buffer from old writer

Yes, that is the purpose of that warning. That is something you must avoid in production systems. /Patrik mån 25 apr. 2016 kl. 18:40 skrev Tim Pigden : > problem due to error in naming of persistenceIds leading to 2 persistors > with same id > > > On Monday, April 25, 2016

Re: [akka-user] Is it possible to put a cluster singleton on a custom dispatcher?

Easiest is probably to set it on the Props using withDispatcher /Patrik mån 25 apr. 2016 kl. 21:05 skrev Steve Rehrauer : > If I wanted to declare a PinnedDispatcher for use by a singleton, can I do > it? > > I've tried declaring such a dispatcher in the .conf, and then