Hi Guys,
I have a task to schedule a long term task on the cluster. I am thinking to
model this task as an Actor that got deployed remotely. What is the best
approach to do that?
I want to have a way to control the amount of concurrent process I run in
the cluster.
Also the Actor that run the
Hi there Bernd,
I think this is more of a Spring Security question... I don't really know if
those strategies they provide work in such contexts.
In general you could ask such question on a Spring group and explain that the
context needs to survive being used
from one thread at a time, but it co
Make sense, Akka is at-most-one delivery guarantee. Good news
On 18 March 2016 at 10:26, Patrik Nordwall
wrote:
>
>
> On Fri, Mar 18, 2016 at 11:14 AM, Guido Medina wrote:
>
>> Hi Patrik,
>>
>> Good morning news, I think a light framework like Aeron will be most
>> welcome, UDP shouldn't be a p
Hi,
If a graph throws an Exception in any flow I want to restart the graph.
Actually I would love to have something like Akka Actors OneForOneStrategy(
10, Duration.create("1 minute"))
I couldn't find the right hints in the docs. What I am trying right now is
this pseudo code:
Function d
Thanks for the quick response:
Nodes pair or actors pair? I used the wrong convention when describing the
scenario, in both designs I'm sending from node-1 to node-2.
The only difference between the 2 is that design 1 is sending to the same
actor@node-2 and design 2 is cycling the actors@node-2
Hi, there's some things that can be improved here (I'll follow up later),
however the first thing that confused me:
You mention (and handle) text/plain everywhere, yet your CURL example is about
text/csv -
which is different so I'd expect the 404 actually.
Is that a typo or the actual question?
Have you read up on the docs about UDP in Java?
http://doc.akka.io/docs/akka/2.4.2/scala/io-udp.html#Bind__and_Send_
-- konrad
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>
Thanks for sharing Lomig!
I only skimmed through so far but looks very good already!
I've added it to my board of things to look at in detail, it's a bit long but I
hope to get there eventually!
You can also add it to the akka.io/community page so people can find it from
there :-)
(We aim to r
Hi,
There is no such thing at the moment.
The onComplete on the sink does not guarantee that the whole stream has
actually stopped, it only guarantees that the Sink itself was stopped
(which may or may not imply completion of the whole stream; think of
graphs).
-Endre
On Fri, Mar 18, 2016 at 11
Message ordering would be challenging to implement with UDP right?
On Friday, March 18, 2016 at 10:20:19 AM UTC, Patrik Nordwall wrote:
>
>
>
> On Fri, Mar 18, 2016 at 11:09 AM, Filippo De Luca > wrote:
>
>> Hi Patrick, what is the advantage of the UPD over TCP if we have to
>> develop the order
Hi,
Is it possible to intercept STDOUT of any other process and stream them via
akka streaming?
Thanks
Arun
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the arch
I’ve been unsuccessful in trying to get an akka-cluster application that works
fine with one instance to work when there are multiple members of the clusters.
A bit of background is in order:
1) the application is an akka-cluster-sharing application
2) it runs in a docker container
3) the clust
Thinking about it maybe this is the expected behaviour and I need to work
with recover?
Am Donnerstag, 17. März 2016 15:12:10 UTC+1 schrieb john@gmail.com:
>
> Hi,
> I am using SupervisionStrategy restart. If I add a Zipper to the graph
> "restart" doesn't work.
>
> What am I doing wrong?
>
One more thing to add to this, in case it is relevant. I see multiple of these
messages in the log:
[akka://ClusterSystem/system/sharding/ExperimentInstanceCoordinator/singleton/coordinator]
stopped
First, why is it stopping (or why does it stop, in general), and secondly, is
it significant
Well, I may be able to answer my own question. It absolutely does matter that
the new remote cluster system is using the same akka-persistence (cassandra
keyspace) store as the old (local) one. When I changed the cassandra keyspace
to a new one, everything started working.
So the question now
i'll try to upgrade. but it is alot of work. i need to replace lots of futures
--
>> 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/
Thanks Konrad, looking forward for your example.
Meanwhile I just discovered how to use reject() to be more specific, like:
reject(UnsupportedRequestContentTypeRejection(Set(
MediaTypes.`text/plain`, ContentTypes.`application/json`
)))
On Friday, 18 March 2016 12:29:30 UTC, Konrad Malawski w
Remember amount of active actors != amount of running processes, you can
have 100 actors monitoring and/or ready to receive a task status but
each actor will only execute something when it receives a message, the
thing to be careful is the dispatcher for the real tasks, these I recommend
you
to
18 matches
Mail list logo