[akka-user] Akka Streams as an ETL tool?

Ive been using Akka streaming for a use case which I dont see much about - that of a small/moderate scale ETL or simple processing pipeline. Im relatively new to it all, so I just wanted to see if I might be missing something that would change my opinion, which is that Akka Streams is among

[akka-user] Access to LoggingAdapter

Is there a way to get hold of the LoggingAdapter used by Akka streams? I'm making use of Viktor's Future retry https://gist.github.com/viktorklang/9414163 and someone would like me to log something in the retry case. So I thought I would add an implicit LoggingAdapter parameter and supply it at

Re: [akka-user] akka-http receiving file upload without copying the file to memory

Alright, thanks for your help, now I see that the problem is in parsing the request I will look into using the `fileUpload` directive. Thanks! On Wed, Jul 13, 2016, at 16:04, Simao Mata wrote: > Ah, that explains it then. > > I am using `formFields('file.as[StrictForm.FileData])` to extract

Re: [akka-user] akka-http receiving file upload without copying the file to memory

Please check the docs: http://doc.akka.io/docs/akka/2.4/scala/http/routing-dsl/directives/file-upload-directives/fileUpload.html And the impl of this directive to gain some more understanding how it works. -- Konrad `ktoso` Malawski Akka @ Lightbend On 13

Re: [akka-user] akka-http receiving file upload without copying the file to memory

Ah, that explains it then. I am using `formFields('file.as[StrictForm.FileData])` to extract the file from the form. So is there a way I can get that data and not put it in memory? Thanks! On Wed, Jul 13, 2016, at 16:00, Konrad Malawski wrote: > `Strict` indicates "the entire thing is in

[akka-user] akka-http receiving file upload without copying the file to memory

Hi, I would like to ask for a clarification on how `mapMaterializedValue` works, I think this might be the cause for this problem. I am trying to receive a large file upload, and I am copying to the file system using something like: val sink = FileIO .toPath(path)

[akka-user] Akka Sen email alerts

Hi All, I would like to use Akka to send real-time alerts (email alerts) as soon as I receive messages. How would I go about it ? Thanks, Padma CH -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

Re: [akka-user] How would you "connect" many independent graphs maintaining backpressure between them?

Ah, sorry, I should've looked more carefully. AFAICT you'll need to figure out what throttling means for a fan-in operation. (Because now you're adding an unbounded queue (the CLQ)) On Sun, Jul 10, 2016 at 4:31 PM, Jack Daniels wrote: > Hi! I use it in the example

Re: [akka-user] Parse multipart/form-data in Java

Thank you Marcelo. Do you have any idea how to build that route using tha Java DSL? On Tuesday, July 12, 2016 at 7:27:52 PM UTC+3, Marcelo Alves wrote: > > Hello Magnus, > You can use this code example -> > https://gist.github.com/jrudolph/08d0d28e1eddcd64dbd0 .. Its works well :) > >> >>

Re: [akka-user] Question about akka-http ssl loose config

I think that should work (although, in general you should *always* prefer real certificates or at least go with an internal ca and sign local certs using that, accepting any will allow for man in the middle attacks, spoofing server etc). Did you try and have any problems with it? -- Johan On

[akka-user] Re: Akka WebSocket as an Api

Any interaction with the "out" actor should probably be inside your HandlerClass actor, I'd call that ChatConnection or something more descriptive. If more actors wants to interact with it you should create protocol for those actions and keep the actual interaction with "out" inside that

Re: [akka-user] Akk Cluster Singletion - Oldest node down message

Hi, In Akka Cluster unreachable and downed are two different things, a node can become unreachable when there is network problems, its JVM is having a long GC pause etc. it may come back from unreachable. Down on the other hand is when a decision has been made about that specific node, that it

Re: [akka-user] Re: How to wait for akka http request

Hi, You are saying "there would be errors", is this something you have seen or are you speculating about the behavior under load? And if it is something seen, what are those errors? -- Johan On Sun, Jul 10, 2016 at 7:25 PM, Sang Dang wrote: > I think you could limit your