Repository: camel Updated Branches: refs/heads/master c912cd8ae -> a5e44fb99
camel-connector - should handle lifecycle of before/after processors Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/dad6c868 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/dad6c868 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/dad6c868 Branch: refs/heads/master Commit: dad6c8688a7cf48eea5a668f4b376f11d74c77dc Parents: c912cd8 Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Apr 11 11:23:51 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Apr 11 11:23:51 2017 +0200 ---------------------------------------------------------------------- .../connector/ConnectorConsumerProcessor.java | 26 ++++++++++++++++++++ .../component/connector/ConnectorProducer.java | 6 ++--- 2 files changed, 29 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/dad6c868/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorConsumerProcessor.java ---------------------------------------------------------------------- diff --git a/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorConsumerProcessor.java b/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorConsumerProcessor.java index aa717ec..53c3860 100644 --- a/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorConsumerProcessor.java +++ b/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorConsumerProcessor.java @@ -20,6 +20,7 @@ import org.apache.camel.AsyncCallback; import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.processor.DelegateAsyncProcessor; +import org.apache.camel.util.ServiceHelper; /** * Connector {@link Processor} which is capable of performing before and after custom processing @@ -65,4 +66,29 @@ public class ConnectorConsumerProcessor extends DelegateAsyncProcessor { return super.process(exchange, delegate); } + @Override + protected void doStart() throws Exception { + ServiceHelper.startServices(beforeConsumer, processor, afterConsumer); + } + + @Override + protected void doStop() throws Exception { + ServiceHelper.stopServices(beforeConsumer, processor, afterConsumer); + } + + @Override + protected void doSuspend() throws Exception { + ServiceHelper.suspendService(processor); + } + + @Override + protected void doResume() throws Exception { + ServiceHelper.resumeService(processor); + } + + @Override + protected void doShutdown() throws Exception { + ServiceHelper.stopAndShutdownServices(beforeConsumer, processor, afterConsumer); + } + } http://git-wip-us.apache.org/repos/asf/camel/blob/dad6c868/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorProducer.java ---------------------------------------------------------------------- diff --git a/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorProducer.java b/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorProducer.java index 2cdc1d7..b5db55d 100644 --- a/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorProducer.java +++ b/connectors/camel-connector/src/main/java/org/apache/camel/component/connector/ConnectorProducer.java @@ -73,12 +73,12 @@ public class ConnectorProducer extends DefaultAsyncProducer { @Override protected void doStart() throws Exception { - ServiceHelper.startService(producer); + ServiceHelper.startServices(beforeProducer, producer, afterProducer); } @Override protected void doStop() throws Exception { - ServiceHelper.stopService(producer); + ServiceHelper.stopServices(beforeProducer, producer, afterProducer); } @Override @@ -93,6 +93,6 @@ public class ConnectorProducer extends DefaultAsyncProducer { @Override protected void doShutdown() throws Exception { - ServiceHelper.stopAndShutdownService(producer); + ServiceHelper.stopAndShutdownServices(beforeProducer, producer, afterProducer); } }
