lib/afterparty/queue.rb in afterparty-0.1.0 vs lib/afterparty/queue.rb in afterparty-0.1.1

@@ -1,20 +1,10 @@
 module Afterparty
   class Queue
     attr_accessor :options, :temp_namespace, :login_block
     include Afterparty::QueueHelpers
 
-    def initialize options={}, consumer_options={}
-      # @consumer = ThreadedQueueConsumer.new(self, consumer_options).start
-      @options = options
-      @options[:namespace] ||= "default"
-      # Afterparty.add_queue @options[:namespace]
-      @options[:sleep] ||= 5
-      @mutex = Mutex.new
-      @options[:logger] ||= Logger.new($stderr)
-    end
-
     def push job
       # @mutex.synchronize do
         return nil if job.nil?
         queue_name = @temp_namespace || @options[:namespace]
         AfterpartyJob.make_with_job job, queue_name
@@ -25,12 +15,10 @@
 
     def pop
       # @mutex.synchronize do
         while true do
           unless (_job = AfterpartyJob.valid.first).nil?
-            ap "poppin job"
-            _job.completed = true
             _job.save
             return _job
           end
           sleep(@options[:sleep])
         end
@@ -39,10 +27,10 @@
   end
   
   class TestQueue < Queue
     attr_accessor :completed_jobs
     
-    def initialize opts={}, consumer_opts={}
+    def initialize opts={}
       super
       @completed_jobs = []
       @exceptions = []
     end
     def handle_exception job, exception
\ No newline at end of file