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 <[email protected]> Authored: Mon Mar 30 11:30:47 2015 +0200 Committer: Hendrik Saly <[email protected]> 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";
