}

    @Override
    public ListenableScheduledFuture<?> scheduleWithFixedDelay(
        Runnable command, long initialDelay, long delay, TimeUnit unit) {
      NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command);
      ScheduledFuture<?> scheduled =
          delegate.scheduleWithFixedDelay(task, initialDelay, delay, unit);

    assertExecutionException(future, ex);
    assertEquals(5, runnable.count);
    assertEquals(0, delegate.getQueue().size());

    runnable = new ThrowingRunnable(5, ex);
    future = service.scheduleWithFixedDelay(runnable, 1, 1, MILLISECONDS);
    assertExecutionException(future, ex);
    assertEquals(5, runnable.count);
    assertEquals(0, delegate.getQueue().size());
  }

            throw new CIFSException("Failed to create CIFSContext for multi-channel transport", e);
        }
    }

    private void startHealthCheckTask() {
        healthCheckExecutor.scheduleWithFixedDelay(this::performHealthCheck, healthCheckInterval, healthCheckInterval,
                TimeUnit.MILLISECONDS);
    }

    private void performHealthCheck() {

        if (cleanupInterval <= 0) {
            cleanupInterval = DEFAULT_LEASE_CLEANUP_INTERVAL;
        }

        final long finalCleanupInterval = cleanupInterval;
        this.cleanupExecutor.scheduleWithFixedDelay(() -> cleanupExpiredLeases(finalCleanupInterval * 2), cleanupInterval, cleanupInterval,
                TimeUnit.MILLISECONDS);
    }

    /**
     * Lease entry containing lease state information
     */

        if (rotationTask != null) {
            rotationTask.cancel(false);
        }

        // Schedule new rotation task
        if (intervalMillis > 0) {
            rotationTask = rotationScheduler.scheduleWithFixedDelay(this::rotateExpiredKeys, intervalMillis, intervalMillis,
                    java.util.concurrent.TimeUnit.MILLISECONDS);
            log.info("Key rotation configured with interval: {} ms", intervalMillis);
        }

        }
        log.info("[{}] Circuit breaker closed and resources cleaned up", name);
    }

    private void startDynamicThresholdAdjustment() {
        thresholdAdjustmentTask = scheduler.scheduleWithFixedDelay(this::performDynamicThresholdAdjustment, 30, 30, TimeUnit.SECONDS);
        log.debug("[{}] Started dynamic threshold adjustment task", name);
    }

    private void performDynamicThresholdAdjustment() {