clusterworker.scala

import akka.actor._
import com.typesafe.config.ConfigFactory

object Program {
  def main(args:Array[String]): Unit ={
    val conf = ConfigFactory.load(ConfigFactory.parseString("""
akka{
  stdout-loglevel = WARN
  loglevel = WARN
  log-config-on-start = off
}
akka.actor {
  provider = "akka.cluster.ClusterActorRefProvider"
}
akka.remote {
  log-remote-lifecycle-events = off
  netty.tcp {
    hostname = "127.0.0.1"
    port = 8090
  }
}
akka.cluster {
  seed-nodes = [
    "akka.tcp://[email protected]:2551"
    "akka.tcp://[email protected]:2552"
    ]
  auto-down = on
}
akka.log-dead-letters=1000
                                                            """))
    val system = ActorSystem.create("ClusterSystem",conf)
    val dummy = system.actorOf(Props[DummyActor],"dummy")
    println("starting node...")
    val res = scala.io.StdIn.readLine()
    println(res)
  }
}


class DummyActor extends Actor {
  def receive = {
    case str:String => println("Msg from " + sender().toString())
  }
}