Class: Streamline::Jobs::HandleEventJob
- Defined in:
- lib/streamline/jobs/handle_event_job.rb
Instance Method Summary collapse
Instance Method Details
#perform(params_dump) ⇒ Object
4 5 6 7 8 9 10 11 12 13 |
# File 'lib/streamline/jobs/handle_event_job.rb', line 4 def perform(params_dump) params = YAML.load(params_dump) handler = params[:handler] event = Streamline.store.find_event(params[:event_id]) return unless conditions_satisfied?(handler, event) handler[:klass].new.run(event) enqueue_repeat(handler, params) end |