Method: Hopper::Channel#queue
- Defined in:
- lib/hopper/channel.rb
permalink #queue(name) ⇒ Object
[View source]
29 30 31 32 33 34 35 36 37 38 39 40 |
# File 'lib/hopper/channel.rb', line 29 def queue(name) if @queues.has_key?(name) @queues[name] else #TODO: This violates SRP. We both manage caching the queues and #constructing a bunch of intermediate objects. I'm wondering if this #belongs more in a factory somewhere else. queue = Hopper::Queue.new(name) proxy = Hopper::Channel::Proxy.new(self, @bunny) @queues[name] = Hopper::Channel::Queue.new(proxy, queue) end end |