ehp / AkkaChat.scala

Created May 14, 2013


    
    View AkkaChat.scala 
  
  
      AkkaChat.scala
    
    
        Raw
      
    
    File suppressed. Click to show.
  
  
            1
            2
            3
            4
            5
            6
            7
            8
            9
            10
            11
            12
            13
            14
            15
            16
            17
            18
            19
            20
            21
            22
            23
            24
            25
            26
            27
            28
            29
            30
            31
            32
            33
            34
            35
          
          
            package com.czechscala.blank
 
import akka.actor._
 
class AkkaChat extends Actor {
  def receive = {
    case (name:String, msg:String) => {
      println("Server: " +name+": "+msg)
      context.actorSelection("../client*") ! (name,msg)
    }
  }
}
 
class AkkaClient extends Actor {
  def receive = {
    case (from:String,msg:String) => {println(self.path.name + ": "+from+": "+msg)}
    case msg:String => {
      context.actorSelection("../server") ! (self.path.name, msg)
    }
  }
 
}
 
object AkkaChat extends App {
  val system = ActorSystem("AkkaChat")
  val actor = system.actorOf(Props[AkkaChat], "server")
 
 
  val cJano = system.actorOf(Props[AkkaClient], "clientJano")
  val cFero = system.actorOf(Props[AkkaClient], "clientFero")
 
  cFero ! "ahoj svete"
  cJano ! "nazdar"
}           }