Repository: camel Updated Branches: refs/heads/master 5ebb037a1 -> b914c04cc
[CAMEL-9351] Kura router should offer SCR programming model. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b914c04c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b914c04c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b914c04c Branch: refs/heads/master Commit: b914c04ccfb0a16020bd4eb0396d51a08804eaa7 Parents: 5ebb037 Author: Henryk Konsek <hekon...@gmail.com> Authored: Mon Nov 23 10:33:25 2015 +0100 Committer: Henryk Konsek <hekon...@gmail.com> Committed: Mon Nov 23 10:33:25 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/kura/KuraRouter.java | 10 ++++++++++ 1 file changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/b914c04c/components/camel-kura/src/main/java/org/apache/camel/component/kura/KuraRouter.java ---------------------------------------------------------------------- diff --git a/components/camel-kura/src/main/java/org/apache/camel/component/kura/KuraRouter.java b/components/camel-kura/src/main/java/org/apache/camel/component/kura/KuraRouter.java index 96865cd..7c5c00b 100644 --- a/components/camel-kura/src/main/java/org/apache/camel/component/kura/KuraRouter.java +++ b/components/camel-kura/src/main/java/org/apache/camel/component/kura/KuraRouter.java @@ -18,6 +18,7 @@ package org.apache.camel.component.kura; import java.io.ByteArrayInputStream; import java.io.InputStream; +import java.util.Map; import org.apache.camel.CamelContext; import org.apache.camel.ConsumerTemplate; @@ -30,6 +31,7 @@ import org.osgi.framework.BundleContext; import org.osgi.framework.ServiceReference; import org.osgi.service.cm.Configuration; import org.osgi.service.cm.ConfigurationAdmin; +import org.osgi.service.component.ComponentContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -93,6 +95,14 @@ public abstract class KuraRouter extends RouteBuilder implements BundleActivator log.debug("Bundle {} stopped.", bundleContext.getBundle().getBundleId()); } + protected void activate(ComponentContext componentContext, Map<String, Object> properties) throws Exception { + start(componentContext.getBundleContext()); + } + + protected void deactivate(ComponentContext componentContext) throws Exception { + stop(componentContext.getBundleContext()); + } + // Callbacks protected CamelContext createCamelContext() {
