Added an API to RoutePolicySupport for stopRoute to control timeout f…

…or graceful shutdown git-svn-id: https://svn.apache.org/repos/asf/camel/trunk@1001004 13f79535-47bb-0310-9956-ffa450edef68
gnodet · Sep 24, 2010 · 35fc173 · 35fc173
1 parent ba65e3a
commit 35fc173
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java b/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java
@@ -16,6 +16,8 @@
  */
 package org.apache.camel.impl;
 
+import java.util.concurrent.TimeUnit;
+
 import org.apache.camel.Consumer;
 import org.apache.camel.Exchange;
 import org.apache.camel.Route;
@@ -71,6 +73,10 @@ protected void stopRoute(Route route) throws Exception {
         route.getRouteContext().getCamelContext().stopRoute(route.getId());
     }
 
+    protected void stopRoute(Route route, long timeout, TimeUnit timeUnit) throws Exception {
+        route.getRouteContext().getCamelContext().stopRoute(route.getId(), timeout, timeUnit);
+    }
+
     /**
      * Handles the given exception using the {@link #getExceptionHandler()}
      *