0

私Actorのように見えます 

object LogProcessorActor {
  def props(f: () => Unit): Props = Props(new LogProcessorActor(f))
}

class LogProcessorActor(f: () => Unit) extends Actor with ActorLogging {
  def receive = LoggingReceive {
    case StartLogReaderDisruptor => f()
      sender ! StartedLogReaderDisruptor
  }
}

そして私のようにtest見えます 

  it must "fail with method throws exception" in {
    val f: () => Unit = () => 2/0
    val logProcessorRef = TestActorRef[LogProcessorActor](LogProcessorActor.props(f), name = "logProcessorSad")
    intercept[ArithmeticException] {
      logProcessorRef ! StartLogReaderDisruptor
    }
  }

例外がスローされたことがログに表示されます 

[DEBUG] [06/02/2015 19:25:44.598] [ScalaTest-run] [EventStream(akka://logProcessorActorSystem)] logger log1-Slf4jLogger started
[DEBUG] [06/02/2015 19:25:44.599] [ScalaTest-run] [EventStream(akka://logProcessorActorSystem)] Default Loggers started
02 Jun 2015 19:25:44,601 [DEBUG] [logProcessorActorSystem-akka.actor.default-dispatcher-3] akka.event.EventStream| logger log1-Slf4jLogger started
02 Jun 2015 19:25:44,603 [DEBUG] [logProcessorActorSystem-akka.actor.default-dispatcher-3] akka.event.EventStream| Default Loggers started02 Jun 2015 19:25:44,782 [ERROR] [logProcessorActorSystem-akka.actor.default-dispatcher-3] akka.actor.OneForOneStrategy| / by zero
java.lang.ArithmeticException: / by zero
    at com.shn.lp.LogProcessorActorSpec$$anonfun$3$$anonfun$4.apply$mcV$sp(LogProcessorActorSpec.scala:18)
    at com.shn.lp.LogProcessorActor$$anonfun$receive$1.applyOrElse(LogProcessorActor.scala:16)
    at akka.actor.Actor$class.aroundReceive(Actor.scala:467)
    at com.shn.lp.LogProcessorActor.aroundReceive(LogProcessorActor.scala:14)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)

しかし、それでも私のテストは失敗します 

Expected exception java.lang.ArithmeticException to be thrown, but no exception was thrown.
ScalaTestFailureLocation: com.shn.lp.LogProcessorActorSpec$$anonfun$3 at (LogProcessorActorSpec.scala:20)
org.scalatest.exceptions.TestFailedException: Expected exception java.lang.ArithmeticException to be thrown, but no exception was thrown.

docsに記載されている戦略も試しましたが、それでも同じ結果が得られます。

私は何を間違っていますか？

4

1 に答える 1

3

アクターの受信ブロックでスローされたキャッチされない例外は、送信者によって処理されません。アクターの監督階層に従って処理されます。親アクターは、スーパーバイザー戦略に従って子を扱います。

これは、ドキュメントのアクターと例外セクションで説明されています: http://doc.akka.io/docs/akka/2.3.11/scala/actors.html#Actors_and_exceptions

于 2015-06-03T05:41:09.193 に答える