Contents

module Cloudist
  class JobQueue < Cloudist::Queues::BasicQueue
    
    # 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

2 entries across 2 versions & 1 rubygems

Version	Path
cloudist-0.4.2	lib/cloudist/queues/job_queue.rb
cloudist-0.4.1	lib/cloudist/queues/job_queue.rb