From e2f496ea9e9cc75661a9b21a2a69ae94b4ead665 Mon Sep 17 00:00:00 2001 From: Mikhail Salosin Date: Wed, 21 May 2014 18:15:25 +0400 Subject: [PATCH] Fix queue clearing --- lib/nsque/testing_worker.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/nsque/testing_worker.rb b/lib/nsque/testing_worker.rb index 9f1e3a1..4922d7d 100644 --- 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)