You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2019/11/26 10:42:57 UTC
[camel-k-runtime] 01/18: YAML: fix ToDynamicStepParser
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 <lb...@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 {