Re: [akka-user] [Cluster Sharding] Futures timed out after [20000 milliseconds] when starting?

2017-02-20 Thread Patrik Nordwall
The only reason I can imagine is that all threads of the default dispatcher are blocked. Please take a few thread dumps if you can reproduce it. I think it will be clear from those what is going on. /Patrik On Thu, Feb 16, 2017 at 6:29 PM, kraythe wrote: > When starting our server in a cluster

[akka-user] Re: Cluster on different nodes minimally sharing code

2017-02-20 Thread klaus . wiederaenders
Okay, so I did my homework myself. I rewrote the 'lightbend's transformation example from akka-sample-cluster-scala' to have separated codebases (JARS) for each role and one for the common messages. It is running not only in different JVMs but also on different cluster nodes (machines). If any

Re: [akka-user] Confused by continuous stream of DistributedPubSub dead letters in Akka Cluster system

2017-02-20 Thread Patrik Nordwall
I would guess that DistributedPubSub is not started on all nodes. You say that you are not using it at all, then the question is who is starting it on some nodes? On Thu, Feb 16, 2017 at 12:51 PM, Artur Soler wrote: > Hi, > > We have an Akka Cluster system with 4 nodes (with 2 different roles: 3

[akka-user] Re: Cluster on different nodes minimally sharing code

2017-02-20 Thread Rafał Krzewski
Great! I'm glad it worked out OK for you :) Maybe you could publish your sample project on github and post a link to this thread? I think people the come across it the future will appreciate it. Cheers, Rafał W dniu poniedziałek, 20 lutego 2017 11:09:18 UTC+1 użytkownik klaus.wie...@gmail.com

Re: [akka-user] newbie question about await inside actors code

2017-02-20 Thread Alan Burlison
On 20 February 2017 at 07:24, Roland Kuhn wrote: > There are two solutions: the pipeTo pattern, or not using Futures at all and > collecting the responses within a dedicated ephemeral actor. What about the "blocking { ... }" construct? http://www.cakesolutions.net/teamblogs/demystifying-the-blo

Re: [akka-user] newbie question about await inside actors code

2017-02-20 Thread Roland Kuhn
> 20 feb. 2017 kl. 12:51 skrev Alan Burlison : > > On 20 February 2017 at 07:24, Roland Kuhn wrote: > >> There are two solutions: the pipeTo pattern, or not using Futures at all and >> collecting the responses within a dedicated ephemeral actor. > > What about the "blocking { ... }" construct?

Re: [akka-user] newbie question about await inside actors code

2017-02-20 Thread Alan Burlison
> This is not a solution because it creates one new thread for every blocker. In general I agree, but if the code has already aggregated all the futures into a single one, as seems to be suggested in an earlier email, wouldn't it be an option - albeit not an ideal one? -- Alan Burlison -- -- >

Re: [akka-user] newbie question about await inside actors code

2017-02-20 Thread Viktor Klang
No. I'd recommend to use stashing, makes the cost explicit. -- Cheers, √ On Feb 20, 2017 12:56 PM, "Alan Burlison" wrote: > > This is not a solution because it creates one new thread for every > blocker. > > In general I agree, but if the code has already aggregated all the > futures into a si

[akka-user] Re: Akka.Http per project request throttling

2017-02-20 Thread Søren Bramer Schmidt
Alright, I now have this version that compiles: import akka.stream._ import akka.stream.scaladsl.GraphDSL.Implicits import akka.stream.scaladsl.{Flow, GraphDSL, Keep, Merge, Sink, Source} val routeFlow: Flow[HttpRequest, HttpResponse, Any] = route val awesomeFlow = Flow[HttpRequest]

[akka-user] Re: akka-http: randomly a client request does not hit the server side, no error messages

2017-02-20 Thread Elmar Weber
Hello Johannes, thanks, yes we will try that next. I have checked the changelogs and found next to connection pool also two others for SSL and TTL related items that can also be the source. https://github.com/akka/akka/issues/21760 https://github.com/akka/akka/issues/20690 Will update and repo

[akka-user] Re: Race condition when injecting adapter providing ClusterClient in Play?

2017-02-20 Thread Elijah Rippeth
Solved . On Friday, February 17, 2017 at 12:45:41 PM UTC-5, Elijah Rippeth wrote: > > Hello all, > > I have found an interesting race condition that is quite likely due to my > design when injecting an adapter which provides a ClusterCli

Re: [akka-user] newbie question about await inside actors code

2017-02-20 Thread Rafał Krzewski
Why use await, when pipeTo pattern provides clean, non-blocking integration between Futures and Actors? As far as I know, the only situation when blocking in actor code is justifiable is interacting with legacy code that just blocks the calling thread and offers no way around it, like JDBC does.

Re: [akka-user] Dependency issue

2017-02-20 Thread Steve Winfield
The exception is not thrown by the player service but by the room service that doesn't load the class (it doesn't use it!) -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Se

Re: [akka-user] Dependency issue

2017-02-20 Thread Justin du coeur
Is the room service receiving a message that contains a players.model.Player? I'd look for some sort of accidental inclusion in a case like this... On Mon, Feb 20, 2017 at 5:10 PM, Steve Winfield < mail.stevewinfi...@gmail.com> wrote: > The exception is not thrown by the player service but by th