This is an automated email from the ASF dual-hosted git repository. martin_s pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/archiva-components.git
commit 335b65e956b4d6a2986c76f0bc14a5ee0af27ac5 Author: Martin Stockhammer <[email protected]> AuthorDate: Thu Nov 21 21:24:37 2019 +0100 Adding Override annotations --- .../org/apache/archiva/components/taskqueue/DefaultTaskQueue.java | 6 ++++++ .../components/taskqueue/execution/ThreadedTaskQueueExecutor.java | 4 ++++ 2 files changed, 10 insertions(+) diff --git a/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/DefaultTaskQueue.java b/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/DefaultTaskQueue.java index 1d63f35..c04c47d 100644 --- a/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/DefaultTaskQueue.java +++ b/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/DefaultTaskQueue.java @@ -62,6 +62,7 @@ public class DefaultTaskQueue // Queue operations // ---------------------------------------------------------------------- + @Override public boolean put( Task task ) throws TaskQueueException { @@ -105,6 +106,7 @@ public class DefaultTaskQueue return true; } + @Override public Task take( ) throws TaskQueueException { @@ -138,6 +140,7 @@ public class DefaultTaskQueue } } + @Override public Task poll( int timeout, TimeUnit timeUnit ) throws InterruptedException { @@ -145,12 +148,14 @@ public class DefaultTaskQueue return queue.poll( timeout, timeUnit ); } + @Override public boolean remove( Task task ) throws ClassCastException, NullPointerException { return queue.remove( task ); } + @Override public boolean removeAll( List tasks ) throws ClassCastException, NullPointerException { @@ -162,6 +167,7 @@ public class DefaultTaskQueue // Queue Inspection // ---------------------------------------------------------------------- + @Override public List<Task> getQueueSnapshot( ) throws TaskQueueException { diff --git a/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/execution/ThreadedTaskQueueExecutor.java b/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/execution/ThreadedTaskQueueExecutor.java index 4042435..05c50da 100644 --- a/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/execution/ThreadedTaskQueueExecutor.java +++ b/spring-taskqueue/src/main/java/org/apache/archiva/components/taskqueue/execution/ThreadedTaskQueueExecutor.java @@ -81,6 +81,7 @@ public class ThreadedTaskQueueExecutor private boolean done; + @Override public void run( ) { while ( command != SHUTDOWN ) @@ -110,6 +111,7 @@ public class ThreadedTaskQueueExecutor Future future = executorService.submit( new Runnable( ) { + @Override public void run( ) { try @@ -328,11 +330,13 @@ public class ThreadedTaskQueueExecutor } } + @Override public Task getCurrentTask( ) { return currentTask; } + @Override public synchronized boolean cancelTask( Task task ) { return executorRunnable.cancelTask( task );
