class Actionable::Sweep
Public Class Methods
logger()
click to toggle source
# File lib/actionable/sweep.rb, line 18 def self.logger defined?(Rails) ? Rails.logger : Logger.new(STDOUT) end
perform()
click to toggle source
# File lib/actionable/sweep.rb, line 10 def self.perform Actionable::Recurrence.all.each(&:ensure_scheduled) Actionable::Action.to_do.each(&:enqueue) rescue => e logger.error("Actionable sweep failed with #{Thread.list.count} threads active") raise e end
queue()
click to toggle source
# File lib/actionable/sweep.rb, line 6 def self.queue @queue end