public void handle()

in src/main/java/com/google/cloud/run/kafkascaler/KafkaScaler.java [115:129]

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

    public void handle(HttpExchange exchange) {
      Instant now = Instant.now();
      ImmutableMap<String, String> headers = RequestResponseHandler.getRequestHeaderMap(exchange);
      try {
        selfScheduler.scheduleTasks(now, headers);
        scaler.scale();
        RequestResponseHandler.sendSuccessResponse(exchange);
      } catch (IOException | ExecutionException | InterruptedException e) {
        RequestResponseHandler.sendFailureResponse(exchange, e);
      } catch (RuntimeException e) {
        logger.atSevere().log("Caught unchecked RuntimeException: %s", e.getMessage());
        e.printStackTrace();
        RequestResponseHandler.sendFailureResponse(exchange, e);
      }
    }