protected def initializeResponseMap()

in kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala [147:185]

• 26 lines of code
• 1 McCabe index (conditional complexity)

  protected def initializeResponseMap(): collection.mutable.Map[String, ActorRef] =
    new ConcurrentHashMap[String, ActorRef]().asScala

  private def initializeKernel(
    config: Config,
    actorLoader: ActorLoader,
    interpreterManager: InterpreterManager,
    commManager: CommManager,
    pluginManager: PluginManager
  ) = {

    //kernel has a dependency on ScalaInterpreter to get the ClassServerURI for the SparkConf
    //we need to pre-start the ScalaInterpreter
//    val scalaInterpreter = interpreterManager.interpreters("Scala")
//    scalaInterpreter.start()

    val kernel = new Kernel(
      config,
      actorLoader,
      interpreterManager,
      commManager,
      pluginManager
    ){
      override protected[toree] def createSparkConf(conf: SparkConf) = {
        val theConf = super.createSparkConf(conf)

        // TODO: Move SparkIMain to private and insert in a different way
        logger.warn("Locked to Scala interpreter with SparkIMain until decoupled!")

        // TODO: Construct class server outside of SparkIMain
        logger.warn("Unable to control initialization of REPL class server!")

        theConf
      }
    }
    pluginManager.dependencyManager.add(kernel)

    kernel
  }