private def incomingRelay()

in kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/relay/KernelMessageRelay.scala [74:88]

• 12 lines of code
• 4 McCabe index (conditional complexity)

  private def incomingRelay(kernelMessage: KernelMessage) = {
    var messageTypeString = kernelMessage.header.msg_type

    // If this is a special case, transform the message type accordingly
    if (incomingSpecialCases.contains(messageTypeString)) {
      logger.debug(s"$messageTypeString is a special incoming case!")
      messageTypeString = incomingSpecialCases(messageTypeString)
    }

    Try(MessageType.withName(messageTypeString)) match {
      case Success(messageName) => relay(messageName, kernelMessage)
      case Failure(_)           =>
        logger.warn(s"Ignoring unknown message type: $messageTypeString")
    }
  }