Contents

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cloudist-0.5.0	lib/cloudist/queues/job_queue.rb