[akka-user] Akka streams

I'd like to split incoming stream into separate output streams based on a key and (a) maintain separate state for each stream and (b) process each stream for configurable number of elements. Here's pseudocode: groupBy (key,element) -> getState(key) -- >> Read the docs:

[akka-user] Akka HTTP / Spray: Directory Traversal Vulnerability Announcement

Dear users of Akka HTTP and Spray, We have just released akka-http 2.4.11 and spray 1.3.4 with a critical security update for users running akka-http servers on Windows. We were notified (akka/akka-http#346 ) that on Windows akka-http’s

[akka-user] ANNOUNCE: Akka 2.4.11 - Including New Remoting

Dear hakkers, We are proud to announce the release of Akka 2.4.11, which includes the new experimental Akka Remoting, codenamed Artery. Some noteworthy changes in the 2.4.11 release are: - New remoting, see below - Progress of Akka Typed, see below - Fixed an issue where

Re: [akka-user] Control how much cpu are used by the actor system?

That's what containers are for though. Run your jvm in a container and restrict resources available to that one On 30 Sep 2016 19:48, "Roland Kuhn" wrote: > Hi Jean-François, > > the JVM does not offer the functionality you seek, you'll have to use your > operating system’s

Re: [akka-user] Control how much cpu are used by the actor system?

Hi Jean-François, the JVM does not offer the functionality you seek, you'll have to use your operating system’s capabilities to restrict the resources available to the JVM itself. Regards, Roland Sent from my iPhone > On 30 Sep 2016, at 18:29, Jean-François Côté

[akka-user] Re: akka shutdown pattern

Hi, Actor system is built to support failure, this time it can be the deployment, the other time a network failure, etc. You never know. You must code something in the backend that will handle the retrying and wait for a completion message and then update its state to "completed". If your

[akka-user] Control how much cpu are used by the actor system?

Hi guys! Is there any way to control how much cpu the akka system use over the total of cpu available in the JVM? For example, I would want all my actor system to only use 75% of the processing power available so that 2 of my 8 core is available for other system on the server. I've checked

[akka-user] Re: akka-stream-scala template dependency not found by Lightbend Activator, so compile fails

The artifact voldemort.store.compress h2-lzf 1.0 is on maven central, so that sounds like problems for sbt accessing the internet (or at least maven central) from your computer, proxy config, firewall? -- Johan Akka Team On Friday, September 30, 2016 at 1:16:43 PM UTC+2, Egor Kraev wrote: > >

[akka-user] Re: akka 2.4.10 - connection reset by peer when consuming stream with parallelism == 1

Yes, Konrad. You nailed it. I can get it to work with parallelism set to 1 and sleep interval tuned down from 50 to 25. This is something I cannot work around from the client side, right? This idle timeout is something set on the server side. I am worried that back pressure is causing my

Re: [akka-user] akka 2.4.10 - connection reset by peer when consuming stream with parallelism == 1

Thank you for your answer, Konrad. I am guessing this shouldn't be the issue, because I have consumed the same stream very slowly using curl --limit-rate 75k. And it took me over 5 minutes to go from end to end. And it worked ell. But I am not sure if akka http handles the socket the same

Re: [akka-user] akka 2.4.10 - connection reset by peer when consuming stream with parallelism == 1

That means the other side has closed the connection. It could be an idle timeout. Are you sure data is consistently flowing, and not being idle for minutes? On 30 Sep 2016 16:59, "Eric Torti" wrote: > Hey guys, > > I am new to akka streams so I may be missing something big

[akka-user] akka 2.4.10 - connection reset by peer when consuming stream with parallelism == 1

Hey guys, I am new to akka streams so I may be missing something big here. Using akka-stream, akka-http-core, akka-typed-experimental all 2.4.10 - scala 2.11.8. I am experiencing the `connection reset by peer` error on a stream that I have checked with `curl` to remain open far longer than

[akka-user] akka-stream-scala template dependency not found by Lightbend Activator, so compile fails

Hi, I downloaded Lightbend Activator from here http://akka.io/downloads/ and tried to load the template akka-stream-scala as indicated here http://www.lightbend.com/activator/template/akka-stream-scala. When I try to compile that inside Activator, I get - [error] (*:update)

[akka-user] thread-pool-executor with fixed-pool-size clarification

I'm trying to understand how thread-pool-executor works. In my config I have: queue-ec { type = Dispatcher executor = "thread-pool-executor" thread-pool-executor { fixed-pool-size = 1 } throughput = 1 } and I have a piece of code that executes following loop - it basically is a

[akka-user] Re: Akka Http Client - Encoding issue

Hi Srinaath, I was wrong. There's no way to let the renderer produce such a URI on the wire. "+" doesn't get percent encoded and "%2b" gets double encoded as "%252b". See [1] for an explanation. However, there's Raw-Request-Uri which you can use. See [2] for an example. [1]

[akka-user] the meaning of Actor.receive and context.become

I'm puzzled by the meaning of Actor.receive() and context.become(..). I was under the impression that Actor.receive() gives you the partial function that determines how incoming messages are handled at this moment. context().become(...) allows you to replace that behavior by another one. But

Re: [akka-user] how to enable secure tcp socket connection on server side in Akka

The library you’re looking for is Akka Streams, not bare Akka IO. Coming from Mina you might want to read http://doc.akka.io/docs/akka/2.4/java/stream/stream-composition.html about how protocol pipelines are expressed.