Contents

# frozen_string_literal: true

module ChronoTrigger
  class Worker < Concurrent::Actor::RestartingContext
    def on_message(event)
      Rails.logger.debug "ChronoTrigger: #{event.inspect}"
      event.perform(*event.args) if event.at.nil? || (event.at && event.before.nil?) || (event.before && event.at < event.before)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
chrono_trigger-1.0.5	lib/chrono_trigger/worker.rb
chrono_trigger-1.0.4	lib/chrono_trigger/worker.rb
chrono_trigger-1.0.3	lib/chrono_trigger/worker.rb
chrono_trigger-1.0.2	lib/chrono_trigger/worker.rb