reply_queue.rb in cloudist-0.4.1

- old
+ new

@@ -1,32 +1,24 @@
 module Cloudist
   class ReplyQueue < Cloudist::Queues::BasicQueue
-    def initialize(queue_name, opts={})
-      opts[:auto_delete] = true
-      opts[:nowait] = false
-      super
+    def initialize(queue_name, options={})
+      options[:auto_delete] = true
+      options[:nowait] = true
+      
+      @prefetch = 2
+      
+      super(queue_name, options)
     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|
+    
+    # def subscribe(&block)
+    #   super do |request|
     #     yield request if block_given?
-    #     self.destroy
+    #     teardown
     #   end
     # end
-    # 
+    
     # def teardown
-    #   @q.delete
+    #   queue.delete
     #   super
     # end
     
   end
 end