Re: [akka-user] Re: Mixing shard regions and proxy to shards regions in the same actor system

2017-10-31 Thread Patrik Nordwall
You're welcome On Tue, Oct 31, 2017 at 11:55 AM, Eduardo Fernandes wrote: > The fixed code. > > > El martes, 31 de octubre de 2017, 11:54:49 (UTC+1), Eduardo Fernandes > escribió: >> >> Fine!! It works like a charm!! >> >> Many thanks Patrik for your time on this!! >> >> I'm

Re: [akka-user] Slow subscribers never get invoked after sometime

2017-10-31 Thread Patrik Nordwall
If these actors blocking while waiting for postgres you might see a starvation issue. All threads in the dispatcher are blocked. You should be able to confirm this with thread dumps, a profiler, or Lightbend’s Thread Starvation Detector. /Patrik mån 30 okt. 2017 kl. 06:56 skrev

[akka-user] Akka Persistance NullPointerException during actor start up

2017-10-31 Thread prashanth . ayyavu
Hi Akka gurus, 1. We use Akka in a production setup 2. We use Cassandra as a back up for akka-persistence. 3. One of the PersistentActors throwed NullPointerException during startup. *The Akka libraries used :* "com.typesafe.akka" %% "akka-actor" % "2.4.17", "com.typesafe.akka" %%

Re: [akka-user] Splitting a stream to be consumed by dynamic sinks

2017-10-31 Thread Jason Steenstra-Pickens
Hi Johan, As far as I can tell this only creates a single Sink based on the first element. I need a dynamic number of Sinks. In the past I have used a custom version of this which creates a new Source for every element ( OneToOneOnDemandSink ).

Re: [akka-user] Splitting a stream to be consumed by dynamic sinks

2017-10-31 Thread Akka Team
Check if sink.lazySink.lazyInit() doesn't do what you want. -- Johan Akka Team On Tue, Oct 31, 2017 at 12:59 AM, Jason Steenstra-Pickens < thestein...@gmail.com> wrote: > Hi, > > I seem to be encountering a reoccurring problem when using Akka Streams > and haven't found the right client API to

Re: [akka-user] Re: Mixing shard regions and proxy to shards regions in the same actor system

2017-10-31 Thread Eduardo Fernandes
Fine!! It works like a charm!! Many thanks Patrik for your time on this!! I'm attaching the code fixed with your comments. Many thanks for your time on this. It was not clear for me that the role was mandatory. I supposed that a non-role means any. My fault. Happy Halloween and thanks again!

Re: [akka-user] Re: Mixing shard regions and proxy to shards regions in the same actor system

2017-10-31 Thread Patrik Nordwall
In that example you are not using roles at all, which I think is necessary. You need 3 roles: - backend-0 where you start region-0, and start proxy for region-1 with role backend-1 - backend-1 where you start region-1, and start proxy for region-0 with role backend-0 - frontend