camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [1/2] camel git commit: Polished
Date Fri, 06 Oct 2017 11:16:58 GMT
Repository: camel
Updated Branches:
  refs/heads/master fb8d3acd0 -> ac17984f8


Polished


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cda4cb6a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cda4cb6a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cda4cb6a

Branch: refs/heads/master
Commit: cda4cb6a8ba4055160037f0bcef28bc5be9f32df
Parents: fb8d3ac
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Fri Oct 6 12:08:22 2017 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Fri Oct 6 12:08:22 2017 +0200

----------------------------------------------------------------------
 .../main/java/org/apache/camel/model/InterceptDefinition.java   | 5 +----
 .../main/java/org/apache/camel/model/ProcessorDefinition.java   | 2 +-
 2 files changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/cda4cb6a/camel-core/src/main/java/org/apache/camel/model/InterceptDefinition.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/model/InterceptDefinition.java b/camel-core/src/main/java/org/apache/camel/model/InterceptDefinition.java
index 1196133..5acd5b6 100644
--- a/camel-core/src/main/java/org/apache/camel/model/InterceptDefinition.java
+++ b/camel-core/src/main/java/org/apache/camel/model/InterceptDefinition.java
@@ -88,10 +88,7 @@ public class InterceptDefinition extends OutputDefinition<InterceptDefinition>
{
 
                 if (interceptedTarget != null) {
                     // wrap in a pipeline so we continue routing to the next
-                    List<Processor> list = new ArrayList<Processor>(2);
-                    list.add(output);
-                    list.add(interceptedTarget);
-                    return new Pipeline(context, list);
+                    return Pipeline.newInstance(context, output, interceptedTarget);
                 } else {
                     return output;
                 }

http://git-wip-us.apache.org/repos/asf/camel/blob/cda4cb6a/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java b/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
index 500b043..0ac2474 100644
--- a/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
+++ b/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
@@ -411,7 +411,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
      * to using a {@link Pipeline} but derived classes could change the behaviour
      */
     protected Processor createCompositeProcessor(RouteContext routeContext, List<Processor>
list) throws Exception {
-        return new Pipeline(routeContext.getCamelContext(), list);
+        return Pipeline.newInstance(routeContext.getCamelContext(), list);
     }
 
     /**


Mime
View raw message