Class: Nezu::Runtime::Recipient

Inherits:
Object
  • Object
show all
Defined in:
lib/nezu/runtime/recipient.rb

Class Method Summary collapse

Class Method Details

.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