如何测试Akka演员是在Scala创建的

首先我想我可以使用Mockhito模拟或间谍代替上下文,然后验证我调用了actorOf,但是我无法弄清楚注入上下文的方法,而不会破坏Akka测试框架.

然后,我想我可以向工作人员发送一个Identify消息来验证它们是否存在.但是在我看来,这样做是不行的,因为Akka TestKit似乎并没有产生被测试的演员的小孩演员.它只能接受可以支持邻近演员的Testprobe.

class HeartBeatPumpWorker(chatService: ChatService,target: HeartBeatMessageCmd) extends Actor with ActorLogging with
WorkersReference {

  val heartBeatInterval = chatService.getHeartBeatInterval

  val tick = context.system.scheduler.schedule(0 millis,heartBeatInterval millis,self,SendHeartBeat(target))

  override def postStop() = tick.cancel()

  def receive = {
    case SendHeartBeat(command: HeartBeatMessageCmd) =>
      log.debug("Sending heartbeat")
      //Send heartbeat to GWT
      val userTarget = NetworkWorker.buildEventUserTarget(command.getEventCode,command.getUser)

      val uuid: String = UUID.randomUUID().toString
      val freshCommand = new HeartBeatMessageCmd(command.getUser,command.getEventCode,uuid,command.getUserSession)
      networkWorker ! NetworkBroadcast(userTarget,freshCommand)

      val heartBeatId: String = freshCommand.getUuid
      //create expirer
      val heartBeatExpireWorkerRef = context.actorOf(HeartBeatExpireWorker.props(chatService,freshCommand),HeartBeatExpireWorker.name(heartBeatId))
      val heartBeatAccepterRef = context
        .actorOf(HeartBeatAcceptWorker.props(chatService,HeartBeatAcceptWorker.name(heartBeatId))

      //record heartbeat
        chatService.saveSentHeartbeat(heartBeatId,freshCommand.getUserSession,freshCommand.getEventCode,freshCommand.getUser,freshCommand.getTimeCmdGenerated)
    case _ =>
      log.error("Pumper received unknown message.  This shouldn't happen " + sender.path.toString)
      self ! PoisonPill
  }

}


object HeartBeatPumpWorker {
  def name(eventCode: String,user: String,sessionId: String) = f"HeartBeatPumpWorker-$eventCode-$user-$sessionId"

  def path(eventCode: String,sessionId: String) : String = {
    EventWorker.Path + "/" + name(eventCode,user,sessionId)
  }

  def props(chatService: ChatService,heartBeatMsgCmd: HeartBeatMessageCmd) = {
    Props(classOf[HeartBeatPumpWorker],chatService,heartBeatMsgCmd)
  }
}