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, ={}) subscriber = Promiscuous::Subscriber::AMQP.subscriber_for(payload) return payload if subscriber.nil? sub = subscriber.new(.merge(:payload => payload)) sub.process if sub.respond_to?(:process) sub.instance end |