5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
# File 'lib/sidekiq/plugins/later/method.rb', line 5
def later(method_name, opts={})
alias_method "now_#{method_name}", method_name
return unless Kiqit.config.enabled?
define_method "#{method_name}" do |*args|
loner = opts.fetch(:loner, false)
queue = opts.fetch(:queue, :generic)
delay = opts.fetch(:delay, false)
klass = Kiqit::Workers::ActiveRecord::Worker
klass = Kiqit::Workers::ActiveRecord::LoneWorker if loner
args = Kiqit::ArgsParser.args_to_sidekiq(args)
digest = Kiqit::PayloadHelper.get_digest(klass, method_name, args)
if loner
return "AR EXISTS!" if Sidekiq.redis{|i| i.get(digest).present?}
Sidekiq.redis{|i| i.set(digest, 'EXISTS')}
end
job = Kiqit::JobCreator.new(queue, klass, send(:class).name, send(:id), "now_#{method_name}", *args)
job.enqueue(delay)
end
end
|