Akka2.0-RC1 example of using futures to re-start long running task

gistfile1.scala

import akka.actor.{ Props, ActorSystem, Actor }
import akka.pattern.ask
import akka.util.Timeout
import akka.util.duration._
import akka.dispatch.Await
import util.Random

object DangerousOpTest extends App {
  println("starting system")
  val system = ActorSystem("daOp")
  system.actorOf(Props[ActorA]) ! "start"

  def done = {
    println("shutting system down")
    system.shutdown()
  }
}

class ActorA extends Actor {
  implicit val timeout = Timeout(5000 milliseconds)
  def receive = {
    case "start" ⇒
      println("calling A")
      val future = context.actorOf(Props[ActorB]) ? "execute"
      future onComplete {
        case Right(result) ⇒
          println("got result: " + result)
          DangerousOpTest.done
        case Left(failure) ⇒
          println("Got failure: re-running self...")
          self ! "start"
      }
  }
}

class ActorB extends Actor {
  lazy val dangerousThingy = new DangerousThingy
  def receive = {
    case "execute" ⇒
      println("executing da op")
      sender ! dangerousThingy.doIt
  }
}

class DangerousThingy {
  def doIt: Int = {
    val executionTimeInMillis = new Random().nextInt(20000)
    println("sleeping for      : " + executionTimeInMillis)
    Thread.sleep(executionTimeInMillis)
    println("done sleeping for : " + executionTimeInMillis)
    executionTimeInMillis
  }
}