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