simple example for scala remote actor with supervision

Server.scala

import scala.actors.Actor._
import scala.actors.remote.RemoteActor._
import scala.concurrent.ops._
import scala.actors.{ Actor, Exit }
object Server extends App {

	def f(msg:Any):String = { 
		println("I received: " + msg)
		"Thanks: " + msg
	}

	class Dispatcher(worker:Actor) extends Actor {

		def act() {
			alive(10000)
			register('ragtime, self)
			println("Server started...")
			loop {
				react {
					case msg =>  worker.forward(msg)
				}
			}
		}
	}

	class Worker(keepAlive:Actor) extends Actor {
		def act() {
			link(keepAlive)
			loop {
				react {
					case 'kill => {
						exit()
					}
					case msg =>  reply(f(msg))

				}
			}
		}
	}

	class KeepAlive extends Actor {

		def act() {
			trapExit = true
			loop {
				react {
					case Exit(from, reason) => {
						Console.println(reason)
						from match {
							case f: Worker => {
								f.restart()
							}
						}
					}
				}
			}
		}
	}

    
	val keepAlive = new KeepAlive()
	keepAlive.start()
	val worker = new Worker(keepAlive)
	worker.start()
	val dispatcher = new Dispatcher(worker)
	dispatcher.start()

}