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
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
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
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
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
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
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
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
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