diff options
Diffstat (limited to 'lib/custodian/queue.rb')
-rw-r--r-- | lib/custodian/queue.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/custodian/queue.rb b/lib/custodian/queue.rb index e9ba830..51d3a3c 100644 --- a/lib/custodian/queue.rb +++ b/lib/custodian/queue.rb @@ -94,7 +94,7 @@ end def fetch(timeout = 1) job = nil - while(true) + loop do foo, job = @redis.blpop('queue', :timeout => timeout) @@ -191,7 +191,7 @@ end # Flush the queue, discarding all pending jobs. # def flush! - while(fetch(1)) + while fetch(1) # nop end end |