lib/bunny/queue08.rb in celldee-bunny-0.4.4 vs lib/bunny/queue08.rb in celldee-bunny-0.5.0
- old
+ new
@@ -42,9 +42,10 @@
method = client.next_method
raise Bunny::ProtocolError, "Error declaring queue #{name}" unless method.is_a?(Qrack::Protocol::Queue::DeclareOk)
@name = method.queue
+ client.queues[@name] = self
end
=begin rdoc
=== DESCRIPTION: