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