[akka-user] Re: Question about how Akka streams handles exceptions

I figured it out - I was already using a killswitch in the 'merge cycle retry' stage to close the output end of the MergeHub when the retry-cycle completed, I just needed to call akka.stream.UniqueKillSwitch.abort(Throwable) instead of akka.stream.UniqueKillSwitch.shutdown() when it completed

[akka-user] Re: Question about how Akka streams handles exceptions

>causing the 'error checker' stage to complete 'successfully' Sorry, to be clear, I don't try to swallow the error; is it possible to detect that an outlet was closed because of an error? On Friday, September 22, 2017 at 10:50:27 AM UTC-7, Bwmat wrote: > > Oh.. I think I might know what's

Re: [akka-user] Question about how Akka streams handles exceptions

Oh, and 'in_requestToResponseFlow` is defined as final Flow, Pair, RequestContext>, NotUsed> in_requestToResponseFlow = Flow.>create().map(pair ->

[akka-user] Cluster: Loosing messages when rebalancing

Hi all. I'm using Akka 2.3.13 [I know... a bit old :( ] with Java. A few times I'm loosing messages (in a very intensive concurrent environment). In my case a message is sent to the actor just before the postStop() method is called, indicating that the kill action is sent to it due the

Re: [akka-user] Re: Where to download installer for latest Akka for Windows?

The dependencies are listed here: http://akka.io/docs/ Please use some form or widely accepted built tool, like sbt, gradle or maven to build akka projects. If you really insist on downloading jar files, you can do so directly via searching maven central

[akka-user] Re: Where to download installer for latest Akka for Windows?

Hi, We do not build a zip with all artifacts anymore as they are all published to Maven central. The "normal" way of using the library is through a build tool such as Maven, SBT or Gradle that will handle downloading the artefacts for you. -- Johan Akka Team On Friday, September 22, 2017 at

Re: [akka-user] Re: how can write and read async with socket (councurent) ?

You can see samples of the two APIs in the docs here: Actor based API: http://doc.akka.io/docs/akka/current/scala/io-tcp.html Stream based API: http://doc.akka.io/docs/akka/current/scala/stream/stream-io.html If you are looking for info how to use the Java NIO APIs that is better sought after

[akka-user] Where to download installer for latest Akka for Windows?

Hello ... This is dumb, but after an hour of Googling™ around, I cannot find any Windows install file for the latest Akka (for Scala), which appears to be 2.5.4 . If there's a link to it on the release announcement http://akka.io/blog/news/2017/08/10/akka-2.5.4-released then I'm missing