You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by an...@apache.org on 2015/04/03 13:51:51 UTC
[2/5] karaf-decanter git commit: Added missing @Override,
restore thread interrupted status
Added missing @Override, restore thread interrupted status
Project: http://git-wip-us.apache.org/repos/asf/karaf-decanter/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf-decanter/commit/e991c18d
Tree: http://git-wip-us.apache.org/repos/asf/karaf-decanter/tree/e991c18d
Diff: http://git-wip-us.apache.org/repos/asf/karaf-decanter/diff/e991c18d
Branch: refs/heads/master
Commit: e991c18de6387b9bea1f11bc111006c9e11051aa
Parents: 9a68a08
Author: Hendrik Saly <he...@gmail.com>
Authored: Mon Mar 30 11:30:47 2015 +0200
Committer: Hendrik Saly <he...@gmail.com>
Committed: Mon Mar 30 11:30:47 2015 +0200
----------------------------------------------------------------------
.../karaf/decanter/scheduler/simple/SimpleScheduler.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf-decanter/blob/e991c18d/scheduler/simple/src/main/java/org/apache/karaf/decanter/scheduler/simple/SimpleScheduler.java
----------------------------------------------------------------------
diff --git a/scheduler/simple/src/main/java/org/apache/karaf/decanter/scheduler/simple/SimpleScheduler.java b/scheduler/simple/src/main/java/org/apache/karaf/decanter/scheduler/simple/SimpleScheduler.java
index dd1ee99..d2f8413 100644
--- a/scheduler/simple/src/main/java/org/apache/karaf/decanter/scheduler/simple/SimpleScheduler.java
+++ b/scheduler/simple/src/main/java/org/apache/karaf/decanter/scheduler/simple/SimpleScheduler.java
@@ -52,6 +52,7 @@ public class SimpleScheduler implements Runnable, Scheduler {
}
}
+ @Override
public void run() {
LOGGER.debug("Decanter SimpleScheduler thread started ...");
@@ -67,6 +68,7 @@ public class SimpleScheduler implements Runnable, Scheduler {
try {
Thread.sleep(interval);
} catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
running.set(false);
}
}
@@ -74,6 +76,7 @@ public class SimpleScheduler implements Runnable, Scheduler {
LOGGER.debug("Decanter SimpleScheduler thread stopped ...");
}
+ @Override
public void stop() {
running.set(false);
if (collectors != null) {
@@ -81,6 +84,7 @@ public class SimpleScheduler implements Runnable, Scheduler {
}
}
+ @Override
public void start() {
if (running.compareAndSet(false, true)) {
Thread thread = new Thread(this, "decanter-scheduler-simple");
@@ -88,10 +92,12 @@ public class SimpleScheduler implements Runnable, Scheduler {
}
}
+ @Override
public boolean isStarted() throws Exception {
return running.get();
}
+ @Override
public String state() {
if (running.get()) {
return "Started";