public void handleResponse()

in src/main/java/com/epam/digital/data/platform/starter/actuator/livenessprobe/LivenessStateHandler.java [46:61]

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

  public <T> void handleResponse(T response, Predicate<T> unhealthyResponseCondition) {
    if (unhealthyResponseCondition.test(response)) {
      if (unhealthyConsecutiveRequestsCounter.incrementAndGet() >= livenessProbeFailureThreshold) {
        AvailabilityChangeEvent.publish(
            applicationEventPublisher, this, LivenessResponseBasedState.BROKEN);
      }
    } else {
      unhealthyConsecutiveRequestsCounter.set(0);
      LivenessResponseBasedState currState = applicationAvailability.getState(
              LivenessResponseBasedState.class, LivenessResponseBasedState.BROKEN);
      if (LivenessResponseBasedState.BROKEN.equals(currState)) {
        AvailabilityChangeEvent.publish(
            applicationEventPublisher, this, LivenessResponseBasedState.CORRECT);
      }
    }
  }