Wrap Redis queues in an enumerable.

redis_queue.rb

class RedisQueue
  include Enumerable
 
  def initialize(queue)
    @queue = queue
  end
 
  def each(&block)
    while element = redis.lpop(@queue)
      block.call(*JSON.parse(element))
    end
  end
 
  def push(task)
    redis.rpush(@queue, task)
  end
  alias_method :<<, :push
 
  private
  def redis
    BackgroundQueue.redis
  end
end