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 <[email protected]> Authored: Fri Oct 6 12:08:22 2017 +0200 Committer: Claus Ibsen <[email protected]> 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); } /**
