1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00

Expose delay as sidekiq_delay also, fixes #1393

This commit is contained in:
Mike Perham 2013-12-15 14:16:31 -08:00
parent 06ec7ef30a
commit 13c588cda2
4 changed files with 22 additions and 9 deletions

View file

@ -1,6 +1,10 @@
2.17.1
-----------
- Expose `delay` extension as `sidekiq_delay` also. This allows you to
run Delayed::Job and Sidekiq in the same process, selectively porting
`delay` calls to `sidekiq_delay`. You just need to ensure that
Sidekiq is required **before** Delayed::Job in your Gemfile. [#1393]
- Bump redis client required version to 3.0.6
- Minor CSS fixes for Web UI

View file

@ -22,15 +22,18 @@ module Sidekiq
end
module ActionMailer
def delay(options={})
def sidekiq_delay(options={})
Proxy.new(DelayedMailer, self, options)
end
def delay_for(interval, options={})
def sidekiq_delay_for(interval, options={})
Proxy.new(DelayedMailer, self, options.merge('at' => Time.now.to_f + interval.to_f))
end
def delay_until(timestamp, options={})
def sidekiq_delay_until(timestamp, options={})
Proxy.new(DelayedMailer, self, options.merge('at' => timestamp.to_f))
end
alias_method :delay, :sidekiq_delay
alias_method :delay_for, :sidekiq_delay_for
alias_method :delay_until, :sidekiq_delay_until
end
end

View file

@ -21,15 +21,18 @@ module Sidekiq
end
module ActiveRecord
def delay(options={})
def sidekiq_delay(options={})
Proxy.new(DelayedModel, self, options)
end
def delay_for(interval, options={})
def sidekiq_delay_for(interval, options={})
Proxy.new(DelayedModel, self, options.merge('at' => Time.now.to_f + interval.to_f))
end
def delay_until(timestamp, options={})
def sidekiq_delay_until(timestamp, options={})
Proxy.new(DelayedModel, self, options.merge('at' => timestamp.to_f))
end
alias_method :delay, :sidekiq_delay
alias_method :delay_for, :sidekiq_delay_for
alias_method :delay_until, :sidekiq_delay_until
end
end

View file

@ -19,15 +19,18 @@ module Sidekiq
end
module Klass
def delay(options={})
def sidekiq_delay(options={})
Proxy.new(DelayedClass, self, options)
end
def delay_for(interval, options={})
def sidekiq_delay_for(interval, options={})
Proxy.new(DelayedClass, self, options.merge('at' => Time.now.to_f + interval.to_f))
end
def delay_until(timestamp, options={})
def sidekiq_delay_until(timestamp, options={})
Proxy.new(DelayedClass, self, options.merge('at' => timestamp.to_f))
end
alias_method :delay, :sidekiq_delay
alias_method :delay_for, :sidekiq_delay_for
alias_method :delay_until, :sidekiq_delay_until
end
end