lib/cloudist/queues/job_queue.rb in cloudist-0.4.2 vs lib/cloudist/queues/job_queue.rb in cloudist-0.4.3

@@ -1,7 +1,16 @@
 module Cloudist
   class JobQueue < Cloudist::Queues::BasicQueue
     
+    def initialize(queue_name, options={})
+      options[:auto_delete] = false
+      options[:nowait] = false
+      
+      @prefetch = Cloudist.worker_prefetch
+      puts "Prefetch: #{@prefetch}"
+      super(queue_name, options)
+    end
+    
     # def initialize(queue_name, options={})
     #   @prefetch = 1
     #   # opts[:auto_delete] = false
     #   
     #   super(queue_name, options)