private def isIncomingMessage()

in kernel/src/main/scala/org/apache/toree/utils/MessageLogSupport.scala [62:74]

13 lines of code
11 McCabe index (conditional complexity)


  private def isIncomingMessage(messageType: String): Boolean ={
    MessageType.Incoming.CompleteRequest.toString.equals(messageType) ||
      MessageType.Incoming.ConnectRequest.toString.equals(messageType) ||
      MessageType.Incoming.ExecuteRequest.toString.equals(messageType) ||
      MessageType.Incoming.HistoryRequest.toString.equals(messageType) ||
      MessageType.Incoming.InspectRequest.toString.equals(messageType) ||
      MessageType.Incoming.ShutdownRequest.toString.equals(messageType)||
      MessageType.Incoming.KernelInfoRequest.toString.equals(messageType) ||
      MessageType.Incoming.CommOpen.toString.equals(messageType) ||
      MessageType.Incoming.CommMsg.toString.equals(messageType) ||
      MessageType.Incoming.CommClose.toString.equals(messageType) ||
      MessageType.Incoming.IsCompleteRequest.toString.equals(messageType)
  }