You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/02/18 06:38:32 UTC
[2/2] git commit: CAMEL-7215 Stop and un-schedule jobs on route
removal. (see CronScheduledRoutePolicy).
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/1cb65780
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1cb65780
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1cb65780
Branch: refs/heads/master
Commit: 1cb657806186e31ddf3ea370d8af88cd150ecaa1
Parents: b1f1233
Author: David Keen <dk...@gmail.com>
Authored: Mon Feb 17 17:14:28 2014 +0000
Committer: Willem Jiang <wi...@gmail.com>
Committed: Tue Feb 18 13:37:50 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/1cb65780/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/1cb65780/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;
}