private def outgoingRelay()

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

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

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

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

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