Акка EventHandler крутится вечно. Как мне это остановить? - PullRequest
Новая
       7

Акка EventHandler крутится вечно. Как мне это остановить?

1 голос
/ 29 ноября 2011

Я думаю, что нашел проблему с EventHandler. Приведенная ниже спецификация будет работать вечно. В основном это будет EventHandler.info(). Я попытался позвонить EventHandler.shutdown(), используя спецификацию After. Но без удачи. Как вы думаете, я что-то упустил?

Акка: 1,3-RC1 

class EventHandlerProblem extends Specification {

  def is =
    "This describes a possible problem with the EventHandler" ^
      p ^
      "The EventHandler should" ^
      "not keep spinning forever...." ! e1

  end

  def e1 = {
    // no need to start the actor
    val ac = TestActorRef[PrintMessageActor]

    true must beTrue
  }
}

class PrintMessageActor extends Actor {
  EventHandler.info(this, "Printer actor is starting up...")

  def receive = {
    case msg => {
      println("Recieved: " + msg)
    }
  }
}

Ответы [ 2 ]

2 голосов
/ 29 ноября 2011

В моих тестах Akka Actor у меня есть особая черта, которая вызывает registry.shutdownAll после запуска всех фрагментов. Таким образом, несмотря на то, что вам по-прежнему необходимо соблюдать осторожность, чтобы ваши тесты могли работать параллельно, не наступая друг на друга, после выполнения всех тестов все будет очищено. Вот черта: 

import org.specs2.Specification
import org.specs2.specification.{Step,Fragments}
import akka.actor.Actor.registry
trait AkkaSpec extends Specification {
  override def map(fs: => Fragments) = fs ^ Step(registry.shutdownAll)
}

class EventHandlerProblem extends AkkaSpec {

  def is =
    "This describes a possible problem with the EventHandler" ^
      p ^
      "The EventHandler should" ^
      "not keep spinning forever...." ! e1

  end

  def e1 = {
    // no need to start the actor
    val ac = TestActorRef[PrintMessageActor]

    true must beTrue
  }
}

class PrintMessageActor extends Actor {
  EventHandler.info(this, "Printer actor is starting up...")

  def receive = {
    case msg => {
      println("Recieved: " + msg)
    }
  }
}
1 голос
/ 29 ноября 2011

Я пытался с EventHandler.shutdown(), и он работал правильно (не вешая трубку). Вот вывод: 

Testing started at 11:03 ...
[INFO]    [29/11/11 11:03] [specs2.DefaultExecutionStrategy1] [PrintMessageActor] Printer actor is starting up...
[INFO]    [29/11/11 11:03] [specs2.DefaultExecutionStrategy2] [PrintMessageActor] Printer actor is starting up...
Process finished with exit code 0

И код: 

import akka.testkit.TestActorRef
import org.specs2.Specification
import akka.event.EventHandler

class EventHandlerProblemSpec extends Specification {

  def is =
    "This describes a possible problem with the EventHandler" ^
      p ^
      "The EventHandler should" ^
      "not keep spinning forever...." ! e1 ^
      "not keep spinning forever 2...." ! e2 ^
      end

  def e1 = {
    {
      val ac = TestActorRef[PrintMessageActor]
      true must beTrue
    } after {
      EventHandler.shutdown()
    }
  }

  def e2 = {
    try {
      val ac = TestActorRef[PrintMessageActor]
      true must beTrue
    } finally {
      EventHandler.shutdown()
    }
  }
}
...