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)
}