Module: Promiscuous::Subscriber::AMQP::ClassMethods

Defined in:
lib/promiscuous/subscriber/amqp.rb

Instance Method Summary collapse

Instance Method Details

#from=(_) ⇒ Object 



20
21
22
23
24
25
 
# File 'lib/promiscuous/subscriber/amqp.rb', line 20

def from=(_)
  super
  old_sub = Promiscuous::Subscriber::AMQP.subscribers[from]
  raise "The subscriber '#{old_sub}' already listen on '#{from}'" if old_sub
  Promiscuous::Subscriber::AMQP.subscribers[from] = self
end