this.healthCheckInterval = getHealthCheckIntervalFromConfig(config);

        // Create thread pools
        this.channelExecutor = Executors.newCachedThreadPool(r -> {
            Thread t = new Thread(r, "SMB3-MultiChannel-Worker");
            t.setDaemon(true);
            return t;
        });

    private final Map<String, FailoverState> failoverStates;
    
    public ChannelFailover(ChannelManager manager) {
        this.manager = manager;
        this.executor = Executors.newCachedThreadPool();
        this.failoverStates = new ConcurrentHashMap<>();
    }
    
    public static class FailoverState {
        private final String channelId;
        private final long failureTime;

  @Test
  fun credentials() {
    val basic: String = Credentials.basic("", "")
  }

  @Test
  fun dispatcher() {
    var dispatcher = Dispatcher()
    dispatcher = Dispatcher(Executors.newCachedThreadPool())
    val maxRequests: Int = dispatcher.maxRequests
    dispatcher.maxRequests = 0
    val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost
    dispatcher.maxRequestsPerHost = 0

  @Disabled
  fun synchronousRequest(protocol: Protocol) {
    setUp(protocol)
    server.enqueue(MockResponse(body = "A"))
    server.enqueue(MockResponse(body = "A"))
    val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test"))
    val countDownLatch = CountDownLatch(2)
    executor.execute(AsyncRequest("/r1", countDownLatch))
    executor.execute(AsyncRequest("/r2", countDownLatch))