Re: [akka-user] [Akka-Cluster] PubSub Extension makes the cluster crash.

2016-10-20 Thread Patrik Nordwall
Hi Philippe, You can use the cluster node role to use pub-sub on a subset of nodes. You have to start the extension on all nodes with the given role. I would be interested in taking a look at the logs from such a "crash". I would expect that messages would be dropped, but nothing more. I would

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

2016-10-20 Thread Rafał Krzewski
W dniu czwartek, 20 października 2016 20:28:26 UTC+2 użytkownik Sergey Sopin napisał: > > Rafał, > > - If I understand onPulI() function correctly, it is allowed only for > outlets, so in order to pull something you need to push it in this outlet > firstly. > > Here's how I understand how this

[akka-user] Combining Kafka, Akka Streams and (Persistent) Actors

2016-10-20 Thread Richard Rodseth
Short version: is it fair to say the traditional warnings against ask() hold less weight because we have back-pressure? In the past I've built an Akka app (no ask() pattern except at the outer edge), and a tool that used Akka Streams (no visible actors except a monitor updated with alsoTo), but

[akka-user] [Akka-Cluster] PubSub Extension makes the cluster crash.

2016-10-20 Thread Philippe N.
Hello, We are new at using Akka in general. So far we managed to create a cluster with the following components: Seeds Cluster-manager (simply display the status of componenents) Backend Frontend Recently we decided to add the pubsub extension to the backend and frontend. However introducing

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

2016-10-20 Thread Sergey Sopin
Rafał, - If I understand onPulI() function correctly, it is allowed only for outlets, so in order to pull something you need to push it in this outlet firstly. - Balancer has been taken from the docs: Balancing_jobs_to_a_fixed_pool_of_workers

[akka-user] withSupervisionStrategy passed a japi Function but compiler complains that its expecting a scala Function1

2016-10-20 Thread murtuza chhil
Having trouble setting up withSupervisionStrategy for the materializer. I get a compile time error of Error:(30, 23) java: no suitable method found for withSupervisionStrategy(akka.japi.function.Function) method

[akka-user] Logger specified in config can't be loaded [akka.event.slf4j.Slf4jLogger]

2016-10-20 Thread Gerard Vico
Hi, I am working in a project with Scala and Akka. Two days ago, I can't launch the test because this error is thrown: [WARN] [10/20/2016 15:47:32.743] [pool-1-thread-1] [EventStream(akka://default)] Logger log1-Slf4jLogger did not respond within Timeout(5000 milliseconds) to

[akka-user] Re: ANNOUNCE: Akka HTTP 3.0.0-RC1

2016-10-20 Thread Sriram P
Awesome! Its really a good news to get the stable release of akka-http. Thanks a lot for the great effort. It will be great if some creates a sample application with the stable release for authentication, oauth2 and authorization. Best Regards, Sriram On Tuesday, 18 October 2016 03:52:17

Re: [akka-user] Re: [akka-stream] Problems with the shape creation

2016-10-20 Thread Rafał Krzewski
Sergey, I have a few remarks after cursory reading of your code: - Akka Streams (and Reactrive Streams) are pull based. As the messages travel downstream, virtual demand tokens travel upstream. Each graph element is allowed to push elements downstream only when demand is signaled. This means