state.incrementRetry();

        // For test purposes, execute recovery immediately without delay
        // In production, this might use the delay from getNextRetryTime()
        executor.submit(() -> attemptRecoveryWithTransport(channel, state, newTransport));
    }

    private void attemptRecovery(ChannelInfo channel, FailoverState state) {
        try {