diff options
| author | Mike Perham <mperham@gmail.com> | 2014-05-20 08:44:00 -0700 |
|---|---|---|
| committer | Mike Perham <mperham@gmail.com> | 2014-05-20 08:44:00 -0700 |
| commit | 2aa9024eede567ae4daa97df62e32f57265096bc (patch) | |
| tree | 51d3794bd6b247e5715618891be4b65322ed1736 /lib/active_job/enqueuing.rb | |
| parent | a88d9ebc0564111cd6c127a4c953ac4a607c2bf0 (diff) | |
| download | rails-2aa9024eede567ae4daa97df62e32f57265096bc.tar.gz rails-2aa9024eede567ae4daa97df62e32f57265096bc.tar.bz2 rails-2aa9024eede567ae4daa97df62e32f57265096bc.zip | |
Fix boogs, stub not implemented adapters
Diffstat (limited to 'lib/active_job/enqueuing.rb')
| -rw-r--r-- | lib/active_job/enqueuing.rb | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/lib/active_job/enqueuing.rb b/lib/active_job/enqueuing.rb index bb681d1e32..43bce125b5 100644 --- a/lib/active_job/enqueuing.rb +++ b/lib/active_job/enqueuing.rb @@ -32,11 +32,12 @@ module ActiveJob # # Returns truthy if a job was scheduled. def enqueue_at(timestamp, *args) - ActiveSupport::Notifications.instrument "enqueue_at.active_job", adapter: queue_adapter, timestamp: timestamp, job: self, params: args - if Time.now.to_f > timestamp - queue.adapter.queue self, *Parameters.serialize(args) + ts = timestamp.to_f + ActiveSupport::Notifications.instrument "enqueue_at.active_job", adapter: queue_adapter, timestamp: ts, job: self, params: args + if Time.now.to_f > ts + queue_adapter.queue self, *Parameters.serialize(args) else - queue_adapter.queue_at self, timestamp.to_f, *Parameters.serialize(args) + queue_adapter.queue_at self, ts, *Parameters.serialize(args) end end end |