From 9b319a53fa880a2407c4836a25f3637d4891fad9 Mon Sep 17 00:00:00 2001
From: Nicholas Bruning <nicholas@bruning.com.au>
Date: Thu, 21 Aug 2014 04:19:40 +0000
Subject: Added enqueue_at support for QueAdapter in ActiveJob

* Added inline job runner for Que in test/support
* Updated QueAdapter to support enqueue_at
---
 activejob/test/adapters/que.rb       | 2 ++
 activejob/test/support/que/inline.rb | 9 +++++++++
 2 files changed, 11 insertions(+)
 create mode 100644 activejob/test/support/que/inline.rb

(limited to 'activejob/test')

diff --git a/activejob/test/adapters/que.rb b/activejob/test/adapters/que.rb
index 640061bf54..e6abc57457 100644
--- a/activejob/test/adapters/que.rb
+++ b/activejob/test/adapters/que.rb
@@ -1,2 +1,4 @@
+require 'support/que/inline'
+
 ActiveJob::Base.queue_adapter = :que
 Que.mode = :sync
diff --git a/activejob/test/support/que/inline.rb b/activejob/test/support/que/inline.rb
new file mode 100644
index 0000000000..2e210acb6b
--- /dev/null
+++ b/activejob/test/support/que/inline.rb
@@ -0,0 +1,9 @@
+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)
+    self.run(*args)
+  end
+end
-- 
cgit v1.2.3