public void validate()

in plc4j/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/config/SourceConfig.java [54:74]

• 21 lines of code
• 7 McCabe index (conditional complexity)

    public void validate() throws ConfigException {
        for (Source source : sources) {
            source.validate();
            for (JobReference jobReference : source.getJobReferences()) {
                Boolean found = false;
                for (Job job : jobs) {
                    if (jobReference.getName().equals(job.getName())) {
                        found = true;
                        break;
                    }
                }
                if (!found) {
                    throw new ConfigException(
                        String.format("Couldn't find a matching job for job reference %s in source %s ", jobReference.getName(), source.getName()));
                }
            }
        }
        for (Job job : jobs) {
            job.validate();
        }
    }