This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit ee06153cc808a7fc964dfd33cd31ee09d8b5587f Author: lburgazzoli <lburgazz...@gmail.com> AuthorDate: Sun Nov 24 23:07:42 2019 +0100 YAML: fix ToDynamicStepParser --- .../camel/k/loader/yaml/parser/ToDynamicStepParser.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/camel-k-loader-yaml/src/main/java/org/apache/camel/k/loader/yaml/parser/ToDynamicStepParser.java b/camel-k-loader-yaml/src/main/java/org/apache/camel/k/loader/yaml/parser/ToDynamicStepParser.java index 9605824..465bbe3 100644 --- a/camel-k-loader-yaml/src/main/java/org/apache/camel/k/loader/yaml/parser/ToDynamicStepParser.java +++ b/camel-k-loader-yaml/src/main/java/org/apache/camel/k/loader/yaml/parser/ToDynamicStepParser.java @@ -24,18 +24,23 @@ import com.fasterxml.jackson.annotation.JsonIgnore; import org.apache.camel.k.annotation.yaml.YAMLStepParser; import org.apache.camel.k.loader.yaml.model.Step; import org.apache.camel.model.ProcessorDefinition; -import org.apache.camel.model.ToDefinition; import org.apache.camel.model.ToDynamicDefinition; +import org.apache.camel.reifier.ProcessorReifier; +import org.apache.camel.reifier.ToDynamicReifier; import org.apache.camel.util.URISupport; @YAMLStepParser("tod") public class ToDynamicStepParser implements ProcessorStepParser { + static { + ProcessorReifier.registerReifier(Definition.class, ToDynamicReifier::new); + } + @Override public ProcessorDefinition<?> toProcessor(Context context) { - return new ToDynamicDefinition(context.node(Definition.class).getEndpointUri()); + return context.node(Definition.class); } - public static final class Definition extends ToDefinition implements Step.Definition { + public static final class Definition extends ToDynamicDefinition implements Step.Definition { public Map<String, Object> parameters; public Definition() { @@ -47,7 +52,7 @@ public class ToDynamicStepParser implements ProcessorStepParser { @JsonIgnore public String getEndpointUri() { - String answer = uri; + String answer = getUri(); if (parameters != null) { try {