protected def initializeCoreActors()

in kernel/src/main/scala/org/apache/toree/boot/layer/BareInitialization.scala [83:133]
47 lines of code
1 McCabe index (conditional complexity)

  protected def initializeCoreActors(
    config: Config, actorSystem: ActorSystem, actorLoader: ActorLoader
  ) = {
    logger.debug("Creating kernel message relay actor")
    val kernelMessageRelayActor = actorSystem.actorOf(
      Props(
        classOf[KernelMessageRelay], actorLoader, true,
        Map(
          CommOpen.toTypeString -> MessageType.Incoming.CommOpen.toString,
          CommMsg.toTypeString -> MessageType.Incoming.CommMsg.toString,
          CommClose.toTypeString -> MessageType.Incoming.CommClose.toString
        ),
        Map(
          CommOpen.toTypeString -> MessageType.Outgoing.CommOpen.toString,
          CommMsg.toTypeString -> MessageType.Outgoing.CommMsg.toString,
          CommClose.toTypeString -> MessageType.Outgoing.CommClose.toString
        )
      ),
      name = SystemActorType.KernelMessageRelay.toString
    )

    logger.debug("Creating signature manager actor")
    val sigKey = config.getString("key")
    val sigScheme = config.getString("signature_scheme")
    logger.debug("Key = " + sigKey)
    logger.debug("Scheme = " + sigScheme)
    val signatureManagerActor = actorSystem.actorOf(
      Props(
        classOf[SignatureManagerActor], sigKey, sigScheme.replace("-", "")
      ),
      name = SecurityActorType.SignatureManager.toString
    )

    logger.debug("Creating status dispatch actor")
    val statusDispatch = actorSystem.actorOf(
      Props(classOf[StatusDispatch], actorLoader),
      name = SystemActorType.StatusDispatch.toString
    )

    logger.debug("Creating shutdown handler and sender actors")
    val shutdownHandler = actorSystem.actorOf(
      Props(classOf[ShutdownHandler], actorLoader),
      name = MessageType.Incoming.ShutdownRequest.toString
    )
    val shutdownSender = actorSystem.actorOf(
      Props(classOf[GenericSocketMessageHandler], actorLoader, SocketType.Control),
      name = MessageType.Outgoing.ShutdownReply.toString
    )

    (kernelMessageRelayActor, signatureManagerActor, statusDispatch, shutdownHandler, shutdownSender)
  }