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 <hekon...@gmail.com> Authored: Thu Nov 19 22:40:16 2015 +0100 Committer: Henryk Konsek <hekon...@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"; }
