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/12 15:47:26 UTC

camel git commit: [CAMEL-9314] Improve error logging in Kura router

Repository: camel
Updated Branches:
  refs/heads/master 7e28d0af4 -> 02e3bc66b


[CAMEL-9314] Improve error logging in Kura router


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/02e3bc66
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/02e3bc66
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/02e3bc66

Branch: refs/heads/master
Commit: 02e3bc66bcbfef8b46a4c1e24f14af657d8210f5
Parents: 7e28d0a
Author: Henryk Konsek <he...@gmail.com>
Authored: Thu Nov 12 15:47:18 2015 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Thu Nov 12 15:47:18 2015 +0100

----------------------------------------------------------------------
 .../apache/camel/component/kura/KuraRouter.java | 27 ++++++++++++++------
 1 file changed, 19 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/02e3bc66/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 2dfda67..9650da6 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
@@ -42,14 +42,25 @@ public abstract class KuraRouter extends RouteBuilder implements BundleActivator
 
     @Override
     public void start(BundleContext bundleContext) throws Exception {
-        this.bundleContext = bundleContext;
-        log.debug("Initializing bundle {}.", bundleContext.getBundle().getBundleId());
-        camelContext = createCamelContext();
-        camelContext.addRoutes(this);
-        beforeStart(camelContext);
-        camelContext.start();
-        producerTemplate = camelContext.createProducerTemplate();
-        log.debug("Bundle {} started.", bundleContext.getBundle().getBundleId());
+        try {
+            this.bundleContext = bundleContext;
+            log.debug("Initializing bundle {}.", bundleContext.getBundle().getBundleId());
+            camelContext = createCamelContext();
+            camelContext.addRoutes(this);
+            beforeStart(camelContext);
+            camelContext.start();
+            producerTemplate = camelContext.createProducerTemplate();
+            log.debug("Bundle {} started.", bundleContext.getBundle().getBundleId());
+        } catch (Throwable e) {
+            String errorMessage = "Problem when starting Kura module " + getClass().getName() + ":";
+            log.warn(errorMessage, e);
+
+            // Print error to the Kura console.
+            System.err.println(errorMessage);
+            e.printStackTrace();
+
+            throw e;
+        }
     }
 
     @Override