private CamelKafkaConnectorModel createModel()

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

• 22 lines of code
• 4 McCabe index (conditional complexity)

    private CamelKafkaConnectorModel createModel(String json) {
        CamelKafkaConnectorModel model = new CamelKafkaConnectorModel();
        JsonObject obj = JsonMapper.deserialize(json);
        JsonObject wrapper = (JsonObject)obj.get("connector");
        model.setConnectorClass((String)wrapper.get("class"));
        model.setArtifactId((String)wrapper.get("artifactId"));
        model.setGroupId((String)wrapper.get("groupId"));
        model.setType((String)wrapper.get("type"));
        model.setVersion((String)wrapper.get("version"));
        model.setDescription((String)wrapper.get("description"));
        model.setOptions(getConnectorOptionModel(obj));
        if (obj.get("aggregationStrategies") != null) {
            model.setAggregationStrategies((List<String>) obj.get("aggregationStrategies"));
        }
        if (obj.get("converters") != null) {
            model.setConverters((List<String>) obj.get("converters"));
        }
        if (obj.get("transforms") != null) {
            model.setTransforms((List<String>) obj.get("transforms"));
        }
        return model;
    }