You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by he...@apache.org on 2015/11/23 10:33:30 UTC
camel git commit: [CAMEL-9351] Kura router should offer SCR
programming model.
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 <he...@gmail.com>
Authored: Mon Nov 23 10:33:25 2015 +0100
Committer: Henryk Konsek <he...@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() {