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