static void sendFailureResponse()

in src/main/java/com/google/cloud/run/kafkascaler/RequestResponseHandler.java [56:66]

• 9 lines of code
• 2 McCabe index (conditional complexity)

  static void sendFailureResponse(HttpExchange exchange, Exception e) {
    String response = "Failure: " + e.getMessage();

    try (OutputStream os = exchange.getResponseBody()) {
      exchange.sendResponseHeaders(500, Utf8.encodedLength(response));
      os.write(response.getBytes(UTF_8));
    } catch (IOException io) {
      // Processing has already completed. Just log the error.
      logger.atWarning().withCause(io).log("Failed while writing response");
    }
  }