public void consume()

in src/main/java/com/epam/digital/data/platform/langserver/ddmlanguageserver/consumer/LSMessageConsumer.java [40:54]

• 15 lines of code
• 3 McCabe index (conditional complexity)

  public void consume(Message message) throws MessageIssueException, JsonRpcException {
    var json = messageJsonHandler.serialize(message);
    log.trace("Output message: {}", json);
    try {
      if (session.isOpen()) {
        session.sendMessage(new TextMessage(json));
      } else {
        log.warn("Session is closed");
        throw new WebSocketConnectionException("Session is closed");
      }
    } catch (IOException e) {
      log.error("Exception occurs during sending message");
      throw new WebSocketException("Exception occurs during sending message", e);
    }
  }