Repository: camel Updated Branches: refs/heads/camel-2.12.x 41b993d29 -> 887f7c39a
CAMEL-7215 Stop and un-schedule jobs on route removal. (see CronScheduledRoutePolicy). Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/35a9742c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/35a9742c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/35a9742c Branch: refs/heads/camel-2.12.x Commit: 35a9742cfb95ab84b13d8bf9026c0559e92a8288 Parents: 41b993d Author: David Keen <[email protected]> Authored: Mon Feb 17 17:14:28 2014 +0000 Committer: Willem Jiang <[email protected]> Committed: Tue Feb 18 13:46:30 2014 +0800 ---------------------------------------------------------------------- .../routepolicy/quartz/SimpleScheduledRoutePolicy.java | 10 ++++++++++ .../routepolicy/quartz2/SimpleScheduledRoutePolicy.java | 10 ++++++++++ 2 files changed, 20 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/35a9742c/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java ---------------------------------------------------------------------- diff --git a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java index 039eeff..5f6be14 100644 --- a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java +++ b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java @@ -104,6 +104,16 @@ public class SimpleScheduledRoutePolicy extends ScheduledRoutePolicy { return trigger; } + @Override + public void onRemove(Route route) { + try { + // stop and un-schedule jobs + doStop(); + } catch (Exception e) { + throw ObjectHelper.wrapRuntimeCamelException(e); + } + } + public Date getRouteStartDate() { return routeStartDate; } http://git-wip-us.apache.org/repos/asf/camel/blob/35a9742c/components/camel-quartz2/src/main/java/org/apache/camel/routepolicy/quartz2/SimpleScheduledRoutePolicy.java ---------------------------------------------------------------------- diff --git a/components/camel-quartz2/src/main/java/org/apache/camel/routepolicy/quartz2/SimpleScheduledRoutePolicy.java b/components/camel-quartz2/src/main/java/org/apache/camel/routepolicy/quartz2/SimpleScheduledRoutePolicy.java index 95f135e..cda294b 100644 --- a/components/camel-quartz2/src/main/java/org/apache/camel/routepolicy/quartz2/SimpleScheduledRoutePolicy.java +++ b/components/camel-quartz2/src/main/java/org/apache/camel/routepolicy/quartz2/SimpleScheduledRoutePolicy.java @@ -126,6 +126,16 @@ public class SimpleScheduledRoutePolicy extends ScheduledRoutePolicy { return trigger; } + @Override + public void onRemove(Route route) { + try { + // stop and un-schedule jobs + doStop(); + } catch (Exception e) { + throw ObjectHelper.wrapRuntimeCamelException(e); + } + } + public Date getRouteStartDate() { return routeStartDate; }
