diff options
| author | Chris Hanks <christopher.m.hanks@gmail.com> | 2015-03-24 09:25:43 -0400 |
|---|---|---|
| committer | Chris Hanks <christopher.m.hanks@gmail.com> | 2015-03-24 09:25:49 -0400 |
| commit | fdfca02c304d809aac53ebf8094b237d0ba6415e (patch) | |
| tree | c837334357a1606565a12c7ab38d5c59e11a4f8c /activejob/test/support | |
| parent | b663e26544d46c111c5a7f44e269c624653c42e5 (diff) | |
| download | rails-fdfca02c304d809aac53ebf8094b237d0ba6415e.tar.gz rails-fdfca02c304d809aac53ebf8094b237d0ba6415e.tar.bz2 rails-fdfca02c304d809aac53ebf8094b237d0ba6415e.zip | |
Stop using Que's named queues in its ActiveJob adapter.
Diffstat (limited to 'activejob/test/support')
| -rw-r--r-- | activejob/test/support/que/inline.rb | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/activejob/test/support/que/inline.rb b/activejob/test/support/que/inline.rb index 2e210acb6b..0232da1370 100644 --- a/activejob/test/support/que/inline.rb +++ b/activejob/test/support/que/inline.rb @@ -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 |