You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by ak...@apache.org on 2010/09/24 20:15:52 UTC

svn commit: r1001004 - /camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java

Author: akarpe
Date: Fri Sep 24 18:15:52 2010
New Revision: 1001004

URL: http://svn.apache.org/viewvc?rev=1001004&view=rev
Log:
Added an API to RoutePolicySupport for stopRoute to control timeout for graceful shutdown

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java?rev=1001004&r1=1001003&r2=1001004&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/RoutePolicySupport.java Fri Sep 24 18:15:52 2010
@@ -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 @@ public abstract class RoutePolicySupport
         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()}
      *