Module: Promiscuous::Subscriber::AMQP

Extended by:
ActiveSupport::Concern
Includes:
Envelope
Included in:
ActiveRecord, Mongoid, Mongoid::EmbeddedMany, Observer
Defined in:
lib/promiscuous/subscriber/amqp.rb

Defined Under Namespace

Modules: ClassMethods

Class Method Summary collapse

Class Method Details

.subscriber_from(payload) ⇒ Object 



8
9
10
11
12
13
14
15
 
# File 'lib/promiscuous/subscriber/amqp.rb', line 8

def self.subscriber_from(payload)
  if key = payload.is_a?(Hash) ? payload['__amqp__'] : nil
    unless self.subscribers.has_key?(key)
      raise "Unknown binding: '#{key}'"
    end
    self.subscribers[key]
  end
end