Module: Promiscuous::Subscriber

Defined in:
lib/promiscuous/subscriber.rb

Defined Under Namespace

Modules: AMQP, Attributes, CustomClass, Envelope, Polymorphic Classes: Base, Error, Generic, Mongoid

Class Method Summary collapse

Class Method Details

.process(payload, options = {}) ⇒ Object 



6
7
8
9
10
11
12
13
 
# File 'lib/promiscuous/subscriber.rb', line 6

def self.process(payload, options={})
  subscriber = Promiscuous::Subscriber::AMQP.subscriber_for(payload)
  return payload if subscriber.nil?

  sub = subscriber.new(options.merge(:payload => payload))
  sub.process if sub.respond_to?(:process)
  sub.instance
end