Sha256: 0429849b5bfb232e53606eb2b31f13a503d67f365ba7d368e1b4856ab8d97288
Contents?: true
Size: 565 Bytes
Versions: 12
Compression:
Stored size: 565 Bytes
Contents
require 'resque'
module DelayedCron
module Jobs
class Resque
@queue = :cron_job
def self.enqueue_delayed_cron(klass, method_name, options)
unless scheduled?(klass, method_name)
# TODO: need to find resque's equivalent to sidekiq's perform_in method
end
end
def self.scheduled?(klass, method_name)
# TODO: returns true if job is already scheduled
end
def self.perform(klass, method_name, options)
DelayedCron.process_job(klass, method_name, options)
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems