Re: [akka-user] How to pass a Spring security context to all actors in a Akka system?

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

Re: [akka-user] Akka remote communication roadmap?

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

[akka-user] How-to restart a RunnableGraph on failure?

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:

Re: [akka-user] Akka remote small/many messages throughput discussion?

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

Re: [akka-user] UDP server java

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

Re: [akka-user] Re: CORS Support Akka-http

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

Re: [akka-user] How-to restart a RunnableGraph on failure?

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

Re: [akka-user] Akka remote communication roadmap?

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

[akka-user] Intercept STDOUT of other process

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

[akka-user] Can't get akka clustering to work in docker

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

[akka-user] Re: Restart does not work with my zipper? What am I doing wrong?

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

[akka-user] Re: Can't get akka clustering to work in docker

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

[akka-user] Re: Can't get akka clustering to work in docker

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

Re: [akka-user] akka.stream.scaladsl.One2OneBidiFlow$OutputTruncationException$: null exception

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:

Re: [akka-user] Akka HTTP POST accepted media types

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

Re: [akka-user] Re: Scheduling long term processes in cluster

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