This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit d62d2d0dd42b1e688ca3ea3eedeb876ab3cc9e7b
Author: Christoph Deppisch <cdeppi...@redhat.com>
AuthorDate: Wed Nov 23 21:56:04 2022 +0100

    Add option to disable data type registry classpath scan
---
 .../camel/kamelets/utils/format/DefaultDataTypeRegistry.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/DefaultDataTypeRegistry.java
 
b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/DefaultDataTypeRegistry.java
index 18effcc9..d393e6c7 100644
--- 
a/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/DefaultDataTypeRegistry.java
+++ 
b/library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/format/DefaultDataTypeRegistry.java
@@ -53,6 +53,8 @@ public class DefaultDataTypeRegistry extends ServiceSupport 
implements DataTypeR
 
     private DataTypeConverterResolver dataTypeConverterResolver;
 
+    private boolean classpathScan = true;
+
     private final Map<String, List<DataTypeConverter>> dataTypeConverters = 
new HashMap<>();
 
     @Override
@@ -95,7 +97,9 @@ public class DefaultDataTypeRegistry extends ServiceSupport 
implements DataTypeR
     protected void doInit() throws Exception {
         super.doInit();
 
-        dataTypeLoaders.add(new AnnotationDataTypeLoader());
+        if (classpathScan) {
+            dataTypeLoaders.add(new AnnotationDataTypeLoader());
+        }
 
         addDataTypeConverter(new DefaultDataTypeConverter("string", 
String.class));
         addDataTypeConverter(new DefaultDataTypeConverter("binary", 
byte[].class));
@@ -171,6 +175,10 @@ public class DefaultDataTypeRegistry extends 
ServiceSupport implements DataTypeR
         return dataTypeConverters.computeIfAbsent(scheme, (s) -> new 
ArrayList<>());
     }
 
+    public void setClasspathScan(boolean classpathScan) {
+        this.classpathScan = classpathScan;
+    }
+
     @Override
     public CamelContext getCamelContext() {
         return camelContext;

Reply via email to