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

1 entries across 1 versions & 1 rubygems

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