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/04/03 11:38:02 UTC
git commit: CAMEL-7033 take clustering into consideration when stop
the consumer with thanks Arne
Repository: camel
Updated Branches:
refs/heads/master 15565d9aa -> b73edad4d
CAMEL-7033 take clustering into consideration when stop the consumer with thanks Arne
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b73edad4
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b73edad4
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b73edad4
Branch: refs/heads/master
Commit: b73edad4df10722dfdece1edebe5d3bdff8a89d0
Parents: 15565d9
Author: Willem Jiang <wi...@gmail.com>
Authored: Thu Apr 3 17:26:25 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Thu Apr 3 17:37:02 2014 +0800
----------------------------------------------------------------------
.../camel/component/quartz2/QuartzEndpoint.java | 22 ++++++++------------
1 file changed, 9 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/b73edad4/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java b/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java
index 94a2077..1aeb9d0 100644
--- a/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java
+++ b/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java
@@ -66,8 +66,8 @@ public class QuartzEndpoint extends DefaultEndpoint {
private long triggerStartDelay = 500; // in millis second
// An internal variables to track whether a job has been in scheduler or not, and has it paused or not.
- private AtomicBoolean jobAdded = new AtomicBoolean(false);
- private AtomicBoolean jobPaused = new AtomicBoolean(false);
+ private final AtomicBoolean jobAdded = new AtomicBoolean(false);
+ private final AtomicBoolean jobPaused = new AtomicBoolean(false);
public QuartzEndpoint(String uri, QuartzComponent quartzComponent) {
super(uri, quartzComponent);
@@ -210,13 +210,7 @@ public class QuartzEndpoint extends DefaultEndpoint {
jobAdded.set(false);
}
} else if (pauseJob) {
- boolean isClustered = scheduler.getMetaData().isJobStoreClustered();
- if (!scheduler.isShutdown() && !isClustered) {
- LOG.info("Pausing job {}", triggerKey);
- scheduler.pauseTrigger(triggerKey);
-
- jobAdded.set(false);
- }
+ pauseTrigger();
}
// Decrement camel job count for this endpoint
@@ -374,13 +368,15 @@ public class QuartzEndpoint extends DefaultEndpoint {
}
public void pauseTrigger() throws Exception {
- if (jobPaused.get()) {
+ Scheduler scheduler = getComponent().getScheduler();
+ boolean isClustered = scheduler.getMetaData().isJobStoreClustered();
+
+ if (jobPaused.get() || isClustered) {
return;
}
+
jobPaused.set(true);
-
- Scheduler scheduler = getComponent().getScheduler();
- if (scheduler != null && !scheduler.isShutdown()) {
+ if (!scheduler.isShutdown()) {
LOG.info("Pausing trigger {}", triggerKey);
scheduler.pauseTrigger(triggerKey);
}