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/19 22:40:37 UTC
camel git commit: Added PID callback to KuraRouter.
Repository: camel
Updated Branches:
refs/heads/master 1f7264f85 -> 26368f7ab
Added PID callback to KuraRouter.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/26368f7a
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/26368f7a
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/26368f7a
Branch: refs/heads/master
Commit: 26368f7ab7962f4eba1bdbb83f2d161fe31c403e
Parents: 1f7264f
Author: Henryk Konsek <he...@gmail.com>
Authored: Thu Nov 19 22:40:16 2015 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Thu Nov 19 22:40:34 2015 +0100
----------------------------------------------------------------------
.../java/org/apache/camel/component/kura/KuraRouter.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/26368f7a/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 ea10ae1..96865cd 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
@@ -58,7 +58,7 @@ public abstract class KuraRouter extends RouteBuilder implements BundleActivator
camelContext.addRoutes(this);
ConfigurationAdmin configurationAdmin = requiredService(ConfigurationAdmin.class);
- Configuration camelKuraConfig = configurationAdmin.getConfiguration("kura.camel");
+ Configuration camelKuraConfig = configurationAdmin.getConfiguration(camelXmlRoutesPid());
if (camelKuraConfig != null && camelKuraConfig.getProperties() != null) {
Object routePropertyValue = camelKuraConfig.getProperties().get(camelXmlRoutesProperty());
if (routePropertyValue != null) {
@@ -120,7 +120,11 @@ public abstract class KuraRouter extends RouteBuilder implements BundleActivator
// Private helpers
- private String camelXmlRoutesProperty() {
+ protected String camelXmlRoutesPid() {
+ return "kura.camel";
+ }
+
+ protected String camelXmlRoutesProperty() {
return "kura.camel." + bundleContext.getBundle().getSymbolicName() + ".route";
}