Method: Nezu::Runtime::Recipient.new

Defined in:: lib/nezu/runtime/recipient.rb

.new(q) ⇒ `Object`



4
5
6

# File 'lib/nezu/runtime/recipient.rb', line 4

def self.new(q)
  Nezu::Runtime::Producer.descendants.select {|producer| producer.queue_name == q}[0] || (raise RecipientError.does_not_exist(q))
end