AtomicInteger failures = consecutiveFailures.get(key);
            if (failures != null && failures.get() >= MAX_CONSECUTIVE_FAILURES) {
                Long lastFailure = lastFailureTimes.get(key);
                if (lastFailure != null && System.currentTimeMillis() - lastFailure < FAILURE_RECOVERY_TIME) {
                    return true;
                }
            }

            return false;
        } catch (Exception e) {