Re: [akka-user] Akka Persistence - Seeing unexpected high number of journal reads

Thanks for confirming my understanding Patrik On Thursday, January 12, 2017 at 2:08:50 PM UTC-8, Patrik Nordwall wrote: > > Your understanding is correct, it should not read after recovery. One > reason could be that actors are restarted or stopped/started due to > exceptions. > > /Patrik > ons

[akka-user] Akka Persistent Actor stops processing messages

First a thank you to people answering questions. Against first the environment Akka 2.4.11 Scala 2.11.8 Cassandra 3.9 I've been chasing an issue for days where one of my persistent actors appears to stop processing message to the point where the JVM memory grows to 8GB before it gets an out of

Re: [akka-user] IllegalArgumentException during ShardCoordinator failover

That can happen if you had more than one active Sharding Coordinator writing to the same journal table, for example if you had a network partition and used auto-downing that caused the cluster to be split into two separate clusters. These checks are there to find this problem. /Patrik On Fri, Jan

[akka-user] transactors and STM are gone. What conception to use instead?

Sometimes you need to do coordinated work between actors and modify shared state. The state in broad sense is separated by actors, there is no need to share them all. But sometimes there is a need to share small chunk of state and work with it with several actors. How it should be done in the re

Re: [akka-user] transactors and STM are gone. What conception to use instead?

Correction, Agents are not gone. They will be deprecated in 2.5, they are present in 2.4. Just Actors ;-) More is documented in the upcoming migration docs: https://github.com/akka/akka/blob/master/akka-docs/rst/project/migration-guide-2.4.x-2.5.x.rst#agents-are-now-deprecated Agents are now de

Re: [akka-user] akka streams graph is not fully drained when Future[Done] completes

I would like to second this issue. I`m experiencing similar behavior in my use case: I`m trying to download file from s3 and sometimes http entity length does not match contentLength header and subsequent json parsing failing. The code i have (simplified): final def responseEntityAsString(entit

Re: [akka-user] akka streams graph is not fully drained when Future[Done] completes

Just for info: I tried with akka 2.4.16 + akka-http 10.0.2 and with akka 2.4.14. In 2.4.14 i see truncation warnings for One2OneBidi stage logged, in 2.4.16 i don`t have such logs, but issue is still reproducible. On Friday, January 13, 2017 at 4:53:58 PM UTC+1, Kyrylo Stokoz wrote: > > I would

Re: [akka-user] transactors and STM are gone. What conception to use instead?

I'm using akka for desktop application multithreading, so I need only simple akka features that works local. Unfortunately local-only features are unwelcomed in new akka. So I would code some kind of hack like sending local states of both actor to the third actor and suspending until it would r

Re: [akka-user] transactors and STM are gone. What conception to use instead?

You can just use the Agents as was explained in my previous email. We're moving them out, shouldn't really stop you from using it. If you want to officially maintain them let us know. -- Konrad `ktoso` Malawski Akka @ Lightbend On 13 January 2017 at 16:46

[akka-user] QuartzScheduler not taking cron-expression in account

hi, I am using quartz and akka to schedule job. Here is my main class: object Main extends App { val system = ActorSystem("DemoCastSyncSystem") val helloActor = system.actorOf(Props(new DemoCastActor("/Users/amishra/democastproperties.conf","/Users/amishra/log4j.properties")), name = "

[akka-user] akka-streams pattern for async filter

Hi! I'm somewhat new to akka-streams and trying to find the best way to express this flow: Let's say I have a stream of messages of type M for case class M(id: Int, val: String) and I have a source and some sink: MSource .to(Sink.ignore) .run() Now, I want to filter some of those messages

Re: [akka-user] akka-streams pattern for async filter

mapAsync.mapConcat with Future[Option] /Patrik fre 13 jan. 2017 kl. 23:44 skrev jdenizac via Akka User List < akka-user@googlegroups.com>: > Hi! I'm somewhat new to akka-streams and trying to find the best way to > express this flow: > > Let's say I have a stream of messages of type M for > > ca