Fix queue clearing

AlphaB · May 21, 2014 · e2f496e · e2f496e
1 parent d9b093f
commit e2f496e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/nsque/testing_worker.rb b/lib/nsque/testing_worker.rb
@@ -31,7 +31,7 @@ def process_all
     def clear_all
       count = 0
 
-      while @producer.messages_count > count
+      while !@consumer.queue.empty?
         message = @consumer.queue.pop
         @consumer.confirm(message)