[akka-user] How to retrieve a shard region form a different cluster node?

2016-08-29 Thread Mutaz Qasem
In the below code, how cluster node FrontendNode can get reference to the shard region "SomeShardRegion" that is already started in the other cluster node BackendNode? When I try the code below I get this exception: Shard type [SomeShardRegion] must be started first. Note: I don't want to

[akka-user] Re: Can't execute more than 4 requests in parallel

2016-08-29 Thread Andrew Gaydenko
May be without client ? -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user --- You received this message because

[akka-user] Re: Issue with default query parameters and custom unmarshalling

2016-08-29 Thread andrew . meyer
OK, I'll try to get a minimal reproducing case when I have some time. On Monday, August 22, 2016 at 11:26:02 AM UTC-5, andrew...@bottlerocketstudios.com wrote: > > I recently came across an issue when I had used `parameters(…)` with > custom unmarshalling and a default value. I found that >

[akka-user] Re: Can't execute more than 4 requests in parallel

2016-08-29 Thread Leonti Bielski
Hi Jan-Pieter! Thanks for the reply! Yes, it seems like this is the issue, although I'm still having trouble changing the behaviour. I added this to my application.conf: akka.http.client.host-connection-pool.max-connections = 100 But requests are still limited to 4 at a time. println("max

Re: [akka-user] Re: How can I convert a listener pattern into a stream with akka streams?

2016-08-29 Thread Endre Varga
I am not sure a simple listener pattern warrants a full Akka Stream to be involved. Streams starts to shine when you need backpressure, but if you don't need any (because events are rare, or there is no way to meaningfully backpressure) then it might be just too heavyweight and lead to

[akka-user] Re: How can I convert a listener pattern into a stream with akka streams?

2016-08-29 Thread Mark Hammons
Hmm, Ok. As for backpressure, with these there should be none because only the latest values emitted by the listener are useful. So I guess I would set them to have a buffer of size 1 and to drop the oldest elements in the buffer for that effect right? On Monday, August 29, 2016 at 8:33:31 AM