lib/qpush/server/queue.rb in qpush-0.1.4 vs lib/qpush/server/queue.rb in qpush-0.1.6
- old
+ new
@@ -27,10 +27,10 @@
private
# Performs a 'blocking pop' on our redis job list.
#
def retrieve_job
- json = QPush.redis.with { |c| c.brpop(QPush.keys.queue) }
+ json = Server.redis { |c| c.brpop(Server.keys.queue) }
Job.new(JSON.parse(json.last))
rescue => e
raise ServerError, e.message
end
end