add new preconditions for taskqueue

2013-05-31 16:28:41 -07:00 · 2013-05-31 16:28:41 -07:00 · d5c2fd604f
parent 93e7ea3787
commit d5c2fd604f
1 changed files with 1 additions and 0 deletions
--- a/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskQueue.java
+++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskQueue.java
@ -219,6 +219,7 @@ public class TaskQueue

    try {
      Preconditions.checkState(active, "Queue is not active!");
+      Preconditions.checkNotNull(task, "task");

      // If this throws with any sort of exception, including TaskExistsException, we don't want to
      // insert the task into our queue.