Method: QueueMap#consumer

Defined in:: lib/queue_map.rb

#consumer(name) ⇒ `Object`



73
74
75

# File 'lib/queue_map.rb', line 73

def consumer(name)
  consumers[name] ||= QueueMap::Consumer.from_file(consumer_path[name], :strategy => mode || :fork)
end