private void createConnector()

in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorCreateMojo.java [79:102]

23 lines of code
5 McCabe index (conditional complexity)


    private void createConnector() throws Exception {
        getLog().info("Creating camel kafka connector for " + name);
        String sanitizedName = sanitizeMavenArtifactId(name);
        //check if the connector is already created
        File directory = new File(projectDir, "camel-" + sanitizedName + KAFKA_CONNECTORS_SUFFIX);
        if (directory.exists()) {
            if (directory.isDirectory()) {
                getLog().info("Connector " + name + " already exists since a sub directory named: " + directory.getName() + " already exists.");
                if (Boolean.TRUE.equals(overridePomFile)) {
                    getLog().info("Since overridePomFile is " + overridePomFile + " regenerating pom file for connector:" + name + " in directory named: " + directory.getName());
                    generateAndWritePom(sanitizedName, directory);
                    addConnectorAsProjectSubmodule(sanitizedName);
                }
                return;
            } else {
                throw new MojoFailureException("Can not create directory as a file already exists: " + directory);
            }
        }
        if (!directory.mkdirs()) {
            throw new MojoFailureException("Unable to create directory: " + directory);
        }
        generateAndWritePom(sanitizedName, directory);
        addConnectorAsProjectSubmodule(sanitizedName);
    }