Contents

module Cloudist
  class ReplyQueue < Cloudist::Queues::BasicQueue
    def initialize(queue_name, options={})
      options[:auto_delete] = true
      options[:nowait] = false
      
      @prefetch = Cloudist.listener_prefetch
      
      super(queue_name, options)
    end
    
    # def subscribe(&block)
    #   super do |request|
    #     yield request if block_given?
    #     teardown
    #   end
    # end
    
    # def teardown
    #   queue.delete
    #   super
    # end
    
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cloudist-0.4.4	lib/cloudist/queues/reply_queue.rb
cloudist-0.4.3	lib/cloudist/queues/reply_queue.rb