in library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/DefaultDataTypeRegistry.java [101:124]
protected void doInit() throws Exception {
super.doInit();
if (classpathScan) {
dataTypeLoaders.add(new AnnotationDataTypeLoader());
} else if (useDefaultConverters) {
addDataTypeConverter(new ByteArrayDataType());
addDataTypeConverter(new StringDataType());
}
for (DataTypeLoader loader : dataTypeLoaders) {
CamelContextAware.trySetCamelContext(loader, getCamelContext());
loader.load(this);
}
// if applicable set Camel context on all loaded data type converters
dataTypeConverters.values().forEach(converters -> converters.forEach(converter -> {
if (converter instanceof CamelContextAware && ((CamelContextAware) converter).getCamelContext() == null) {
CamelContextAware.trySetCamelContext(converter, camelContext);
}
}));
LOG.debug("Loaded {} schemes holding {} data type converters", dataTypeConverters.size(), dataTypeConverters.values().stream().mapToInt(List::size).sum());
}