Class: Streamline::Jobs::TrackEventJob
- Defined in:
- lib/streamline/jobs/track_event_job.rb
Instance Method Summary collapse
Instance Method Details
#perform(params_dump) ⇒ Object
4 5 6 7 8 9 10 11 12 |
# File 'lib/streamline/jobs/track_event_job.rb', line 4 def perform(params_dump) params = YAML.load(params_dump) event_id = Streamline.store.save_event(params) Streamline.registry[params[:name]].each do |handler| HandleEventJob .set(wait: handler[:delay]) .perform_later(YAML.dump(event_id: event_id, handler: handler)) end end |