CAMEL-11133: Data format - Marshal and unmarshal should eager start their data formats
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a5e44fb9 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a5e44fb9 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a5e44fb9 Branch: refs/heads/master Commit: a5e44fb99e3727c180320c31f84d38b97c86ddad Parents: dad6c86 Author: Claus Ibsen <[email protected]> Authored: Tue Apr 11 11:31:57 2017 +0200 Committer: Claus Ibsen <[email protected]> Committed: Tue Apr 11 11:31:57 2017 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/camel/processor/MarshalProcessor.java | 4 ++-- .../main/java/org/apache/camel/processor/UnmarshalProcessor.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a5e44fb9/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java index 6206a73..349b88c 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/MarshalProcessor.java @@ -110,8 +110,8 @@ public class MarshalProcessor extends ServiceSupport implements AsyncProcessor, ((CamelContextAware) dataFormat).setCamelContext(camelContext); } // add dataFormat as service which will also start the service - // (false => we and handling the lifecycle of the dataFormat) - getCamelContext().addService(dataFormat, false); + // (false => we handle the lifecycle of the dataFormat) + getCamelContext().addService(dataFormat, false, true); } @Override http://git-wip-us.apache.org/repos/asf/camel/blob/a5e44fb9/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java index 3c5183c..4fc1d21 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java @@ -123,8 +123,8 @@ public class UnmarshalProcessor extends ServiceSupport implements AsyncProcessor ((CamelContextAware) dataFormat).setCamelContext(camelContext); } // add dataFormat as service which will also start the service - // (false => we and handling the lifecycle of the dataFormat) - getCamelContext().addService(dataFormat, false); + // (false => we handle the lifecycle of the dataFormat) + getCamelContext().addService(dataFormat, false, true); } @Override
