private void initCatalog()

in camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java [63:86]

23 lines of code
8 McCabe index (conditional complexity)


    private void initCatalog() {
        try (InputStream input = CamelKafkaConnectorCatalog.class.getResourceAsStream("/" + DESCRIPTORS_DIR + "/" + CONNECTORS_PROPERTIES)) {
            BufferedReader reader = new BufferedReader(new InputStreamReader(input));

            while (reader.ready()) {
                String connector = reader.readLine();
                if (connector.equalsIgnoreCase("camel-coap-tcp-source")) {
                    connectorsName.add("camel-coap+tcp-source");
                } else if (connector.equalsIgnoreCase("camel-coaps-tcp-source")) {
                    connectorsName.add("camel-coaps+tcp-source");
                } else if (connector.equalsIgnoreCase("camel-coaps-tcp-sink")) {
                    connectorsName.add("camel-coaps+tcp-sink");
                } else if (connector.equalsIgnoreCase("camel-coap-tcp-sink")) {
                    connectorsName.add("camel-coap+tcp-sink");
                } else {
                    connectorsName.add(connector);
                }
            }
        } catch (FileNotFoundException e) {
            LOG.error("Cannot find file: {}", e.getMessage(), e);
        } catch (IOException e) {
            LOG.error("IO Exception: {}", e.getMessage(), e);
        }
    }