private def initializeSystemActors()

in client/src/main/scala/org/apache/toree/kernel/protocol/v5/client/boot/layers/SystemInitialization.scala [85:115]


  private def initializeSystemActors(
    config: Config, actorSystem: ActorSystem, actorLoader: ActorLoader,
    socketFactory: SocketFactory, commRegistrar: CommRegistrar,
    commStorage: CommStorage
  ) = {
    val signatureEnabled = config.getString("key").nonEmpty

    val heartbeatClient = actorSystem.actorOf(
      Props(classOf[HeartbeatClient],
        socketFactory, actorLoader, signatureEnabled),
      name = SocketType.HeartbeatClient.toString
    )

    val stdinClient = actorSystem.actorOf(
      Props(classOf[StdinClient], socketFactory, actorLoader, signatureEnabled),
      name = SocketType.StdInClient.toString
    )

    val shellClient = actorSystem.actorOf(
      Props(classOf[ShellClient], socketFactory, actorLoader, signatureEnabled),
      name = SocketType.ShellClient.toString
    )

    val ioPubClient = actorSystem.actorOf(
      Props(classOf[IOPubClient], socketFactory, actorLoader, signatureEnabled,
        commRegistrar, commStorage),
      name = SocketType.IOPubClient.toString
    )

    (heartbeatClient, stdinClient, shellClient, ioPubClient)
  }