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

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


The following commit(s) were added to refs/heads/master by this push:
     new f6be79a  CAMEL-15730: camel-core - untangle
f6be79a is described below

commit f6be79acaeb8fd2290a15e77c96c7dc70ac6b326
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Oct 22 16:25:22 2020 +0200

    CAMEL-15730: camel-core - untangle
---
 .../src/main/java/org/apache/camel/reifier/RouteReifier.java          | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/RouteReifier.java
 
b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/RouteReifier.java
index dea09b3..9cf9dd5 100644
--- 
a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/RouteReifier.java
+++ 
b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/RouteReifier.java
@@ -24,6 +24,7 @@ import java.util.StringTokenizer;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
+import org.apache.camel.EndpointConsumerResolver;
 import org.apache.camel.ExtendedCamelContext;
 import org.apache.camel.FailedToCreateRouteException;
 import org.apache.camel.Processor;
@@ -33,7 +34,6 @@ import org.apache.camel.ShutdownRoute;
 import org.apache.camel.ShutdownRunningTask;
 import org.apache.camel.builder.AdviceWithRouteBuilder;
 import org.apache.camel.builder.AdviceWithTask;
-import org.apache.camel.builder.EndpointConsumerBuilder;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.model.Model;
 import org.apache.camel.model.ProcessorDefinition;
@@ -241,7 +241,7 @@ public class RouteReifier extends 
ProcessorReifier<RouteDefinition> {
         // resolve endpoint
         Endpoint endpoint = definition.getInput().getEndpoint();
         if (endpoint == null) {
-            EndpointConsumerBuilder def = 
definition.getInput().getEndpointConsumerBuilder();
+            EndpointConsumerResolver def = 
definition.getInput().getEndpointConsumerBuilder();
             if (def != null) {
                 endpoint = def.resolve(camelContext);
             } else {

Reply via email to