Bug.scala

import akka.actor._
import akka.event.Logging

object Bug extends App {

  ActorSystem("Bug").actorOf(Props[Bug])

}

class Bug extends Actor with FSM[Int, (Int, Int)] {

  import FSM._

  override val log = Logging(context.system, this)

  self ! new Exception("foo")

  startWith(0, (0, 1))

  when(0) {
    case Event('ack, _) =>
      log.info("Received ack")
      stay
    case Event(t: Throwable, _) =>
      log.info("Received throwable " + t)
      self ! new Exception("bar")
      goto(1)
  }

  when(1) {
    case Event('ack, _) =>
      log.info("Received ack")
      stay
    case Ev(t: Throwable) =>
      log.info("Received throwable " + t)
      stop(Normal)
  }

  initialize

}