Re: [akka-user] Akka typed - first impressions

2018-02-04 Thread Tal Pressman
Thanks! I switched my code over to the new version, and once I got past all the Actor -> Behaviors changes everything seems to work very nicely. If you're interested, you can see the code here (it's part of a course, so there isn't much code there ^_^ ): https://github.com/talpr/nex-akka-worksh

[akka-user] Error in request and response async in Tcp Akka on port 25 ?

2018-02-04 Thread techland . co . ir
Hi Every one i wrote this code for read Port 25 class Asker(connection: ActorRef) extends Actor { import Tcp._ connection ! Register(self); def receive = { case x => val parent = sender() connection ! x context become {case x => parent ! x;context.unbecome()} } }

[akka-user] [akka-streams] How to test FanOut shapes?

2018-02-04 Thread Sergii Sopin
Hi, I am writing tests for my application and I want to test function that returns Partition shape with two outlets. Are there any best practices on how to test Partition shapes? Thanks. Regards, Sergii -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Question about multi data center behavior when a data center is empty

2018-02-04 Thread lemmsjid
Hi everyone, I have a question pertaining to the multi data center behavior. In a nutshell, I'm wondering what the expected behavior is if all of the nodes (especially the last one) in a data center go down, and how the other data centers would respond to that. In my experimenting, when the la

Re: [akka-user] Cancel Actor job

2018-02-04 Thread Richard Gong
Thanks Johan. It looks very good. Is there any Java version? I found one on git hub: https://github.com/typesafehub/activator-akka-distributed-workers-java, yet it's an old version 2 years ago and the api being used are obsoleted. > > -- >> Read the docs: http://akka.io/docs/