Re: [akka-user] Akka actors not processing messages after a while

> > . Sometimes you "have to" deviate from that principle and then you have to > carefully manage the complexity that arise. > > > Patrik, Can you give an example when you "have to" deviate and shared mutable state between actors ? Thanks -Soumya -- >> Read the docs: http://

Re: [akka-user] Sequential processing of messages

Hi Patrik First of all, thank you for your reply. 1. Splitting them seems to be the best option. 2. Yes, I'm passing simple HashSet and yes, I'm modifying this set in different actors. So if I understand correctly, I should make them immutable. Are there any tutorials how to do this correctly?

Re: [akka-user] Akka Stream - ExecutionException: Boxed Error

Could you also try val done = source.runWith(sink) done.onComplete You use version 0.11, right? What is the full stackTrace? Try to grab the getCause of the ExecutionException. /Patrik > 28 nov 2014 kl. 15:25 skrev Bertil Chapuis : > > Hi, > > I'm playing with Akka Stream and trying to

Re: [akka-user] Sequential processing of messages

Hi, On Fri, Nov 28, 2014 at 11:06 AM, Erol Merdanović wrote: > Hi > > We have an app (Play Framework) which accepts files from different > devices. Devices are logging some values into a file and send that file > every 5 minutes. The app accepts the file, parses it and processes it. > > Actual s

[akka-user] Akka Stream - ExecutionException: Boxed Error

Hi, I'm playing with Akka Stream and trying to define a Source that listen to file system events with the java nio WatchService. import java.nio.file.StandardWatchEventKinds._ import java.nio.file._ import akka.actor.ActorSystem import akka.stream.FlowMaterializer import akka.stream.scaladsl._

[akka-user] Akka-persistence and supervision

Hello, I'm currently using akka-persistence for a project, with the MongoDB connector . I'd like my persistent actor to attempt restarting a certain number of times if it fails to connect to the database. However, as I tried to set a custom

Re: [akka-user] Akka actors not processing messages after a while

On Wed, Nov 26, 2014 at 11:58 PM, Yogesh wrote: > Hi Martynas, > > I was using mutable hashmap which multiple actors were trying to access. I > think that was creating a deadlock. So after changing it to > ConcurrentTrieMap the problem was resolved. > Thanks for your input. > Glad to see that yo

Re: [akka-user] Using akka-stream to build async pipeline

On Thu, Nov 27, 2014 at 10:44 AM, Leon Ma wrote: > Hi, Konrad > > I have some common questions regarding akka stream. > Say I want to build an async pipeline with akka steam to handle online > http request. (which means response time is prior to throughput) > > Questions: > > 1. 1 pipeline for a

[akka-user] Sequential processing of messages

Hi We have an app (Play Framework) which accepts files from different devices. Devices are logging some values into a file and send that file every 5 minutes. The app accepts the file, parses it and processes it. Actual steps are 1. parse the file 2. recalculate values (we get values as 0-100%,

Re: [akka-user] Akka clusterclient Association Error / ClassNotFoundException when serialising response

Hi Hengky, the log says that you are sending the companion object back and that the front-end node does not have that class. You said that without the dollar sign the class is present but what you need is the class with the dollar sign (if you really want to send the companion object instead of

Re: [akka-user] Akka Streams - Chunked Encoding

Yes, deadletters are harmless here. We are working on suppressing them for streams. /Patrik On Thu, Nov 27, 2014 at 12:05 AM, Rüdiger Klaehn wrote: > I am not completely sure, but the dead letters are probably nothing to > worry about. I had a similar experience when I played around with it a >

Re: [akka-user] Using a BalancingPool with PriorityGenerator

I think that might not work in Akka 2.3.x. It was improved by issue #13964 and corresponding pull request #2127 . Regards, Patrik On Wed, Nov 26, 2014 at 9:34 PM, Jelmer Kuperus wrote: > Hi I am trying to get a

Re: [akka-user] DynamoDB Streams for maintaining CQRS read models?

That is very interesting and useful. Thanks for sharing. /Patrik On Sat, Nov 22, 2014 at 6:45 PM, Andrew Easter wrote: > I was pretty fascinated to read about the introduction of Amazon's DynamoDB > Streams . > Given there are DynamoDB b