kotovalexarian-likes-github/rails--rails
1
0
Fork 0
mirror of https://github.com/rails/rails.git synced 2022-11-09 12:12:34 -05:00
Code Releases Activity

Stop using Que's named queues in its ActiveJob adapter.

Browse source
This commit is contained in:
Chris Hanks 2015-03-24 09:25:43 -04:00
parent b663e26544
commit fdfca02c30
2 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
activejob/lib/active_job/queue_adapters/que_adapter.rb
View file

@ -16,11 +16,11 @@ module ActiveJob
# Rails.application.config.active_job.queue_adapter = :que
class QueAdapter
def enqueue(job) #:nodoc:
JobWrapper.enqueue job.serialize, queue: job.queue_name
JobWrapper.enqueue job.serialize
end
def enqueue_at(job, timestamp) #:nodoc:
JobWrapper.enqueue job.serialize, queue: job.queue_name, run_at: Time.at(timestamp)
JobWrapper.enqueue job.serialize, run_at: Time.at(timestamp)
end
class JobWrapper < Que::Job #:nodoc:

6
activejob/test/support/que/inline.rb
View file

@ -3,7 +3,11 @@ require 'que'
Que::Job.class_eval do
class << self; alias_method :original_enqueue, :enqueue; end
def self.enqueue(*args)
args.pop if args.last.is_a?(Hash)
if args.last.is_a?(Hash)
options = args.pop
options.delete(:run_at)
args << options unless options.empty?
end
self.run(*args)
end
end