Contents

module Cloudist
  class ReplyQueue < Cloudist::Queues::BasicQueue
    def initialize(queue_name, opts={})
      opts[:auto_delete] = true
      opts[:nowait] = false
      super
    end

    def setup(key = nil)
      @mq = MQ.new
      @q = @mq.queue(queue_name, opts)
      @ex = @mq.direct
      if key
        @q.bind(@ex, :key => key)
      else
        @q.bind(@ex)
      end
    end

    # def subscribe(amqp_opts={}, opts={})
    #   super(amqp_opts, opts) do |request|
    #     yield request if block_given?
    #     self.destroy
    #   end
    # end
    # 
    # def teardown
    #   @q.delete
    #   super
    # end
    
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cloudist-0.2.1	lib/cloudist/queues/reply_queue.rb
cloudist-0.2.0	lib/cloudist/queues/reply_queue.rb