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

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


The following commit(s) were added to refs/heads/main by this push:
     new be07956  CAMEL-17806: camel-yaml-dsl - Better parser error with source 
loc:line of the problem
be07956 is described below

commit be07956f78342c8dd267b755eebd2b8480735a0e
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Apr 1 09:17:01 2022 +0200

    CAMEL-17806: camel-yaml-dsl - Better parser error with source loc:line of 
the problem
---
 .../main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
 
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
index e688c43..1849c7c 100644
--- 
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
+++ 
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
@@ -42,6 +42,7 @@ import 
org.apache.camel.component.properties.PropertiesLocation;
 import org.apache.camel.dsl.yaml.common.YamlDeserializationContext;
 import org.apache.camel.dsl.yaml.common.YamlDeserializerSupport;
 import org.apache.camel.dsl.yaml.common.exception.InvalidEndpointException;
+import org.apache.camel.dsl.yaml.common.exception.InvalidNodeTypeException;
 import org.apache.camel.dsl.yaml.deserializers.OutputAwareFromDefinition;
 import org.apache.camel.model.KameletDefinition;
 import org.apache.camel.model.OnExceptionDefinition;
@@ -317,6 +318,10 @@ public class YamlRoutesBuilderLoader extends 
YamlRoutesBuilderLoaderSupport {
                 routes = nodeAt(root, "/spec/flow");
             }
             if (routes != null) {
+                // routes should be an array
+                if (routes.getNodeType() != NodeType.SEQUENCE) {
+                    throw new InvalidNodeTypeException(routes, 
NodeType.SEQUENCE);
+                }
                 answer.add(routes);
             }
         }

Reply via email to