gistfile1.scala

class MyActor extends Actor {

  var driver: ActorRef = null
  val identifyId = //get a unique identifyId for that driverUrl

  override def  preStart() {
    val driverSel = context.actorSelection(driverUrl)
    driverSel ! Identify(identifyId)
  }

  private def waitingForDriver: Receive = {
    case ActorIdentity(identifyId, Some(actorRef)) =>
       val timeout = 100.millis
       driver = context.actorOf(Props(classOf[ReliableProxy], actorRef, timeout))
       driver ! RegisterExecutor(executorId, hostPort, cores)
       context.system.eventStream.subscribe(self, classOf[RemotingLifecycleEvent])
       context watch driver
       context become mainReceive
  }
  
  private def mainReceive: Receive = {
  // the current receive
  }
  
  override def receive = waitingForDriver

}