lib/cloudist/queues/job_queue.rb in cloudist-0.4.4 vs lib/cloudist/queues/job_queue.rb in cloudist-0.5.0

- old
+ new

@@ -1,26 +1,26 @@ 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) # end - + # def setup_exchange # @exchange = channel.direct(queue_name) # queue.bind(exchange) # end - + end end