lib/mq/queue.rb in tmm1-amqp-0.5.2 vs lib/mq/queue.rb in tmm1-amqp-0.5.3

@@ -2,10 +2,10 @@
   class Queue
     include AMQP
     
     def initialize mq, name, opts = {}
       @mq = mq
-      @name = name
+      @mq.queues[@name = name] ||= self
       @mq.callback{
         @mq.send Protocol::Queue::Declare.new({ :queue => name,
                                                 :nowait => true }.merge(opts))
       }
     end
\ No newline at end of file