lib/qpush/server/queue.rb in qpush-0.1.2 vs lib/qpush/server/queue.rb in qpush-0.1.4

@@ -12,11 +12,11 @@
       # Starts our queue process. This will run until instructed to stop.
       #
       def start
         until @done
           job = retrieve_job
-          job.api.setup if job
+          job.setup if job
         end
       end
 
       # Shutsdown our queue process.
       #
@@ -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.config.queue_namespace) }
+        json = QPush.redis.with { |c| c.brpop(QPush.keys.queue) }
         Job.new(JSON.parse(json.last))
       rescue => e
         raise ServerError, e.message
       end
     end