aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/test/support/queue_classic/inline.rb
diff options
context:
space:
mode:
Diffstat (limited to 'activejob/test/support/queue_classic/inline.rb')
-rw-r--r--activejob/test/support/queue_classic/inline.rb17
1 files changed, 10 insertions, 7 deletions
diff --git a/activejob/test/support/queue_classic/inline.rb b/activejob/test/support/queue_classic/inline.rb
index 5743d5bbb5..0695a34c27 100644
--- a/activejob/test/support/queue_classic/inline.rb
+++ b/activejob/test/support/queue_classic/inline.rb
@@ -1,21 +1,24 @@
-require 'queue_classic'
+# frozen_string_literal: true
+
+require "queue_classic"
+require "active_support/core_ext/module/redefine_method"
module QC
class Queue
- def enqueue(method, *args)
- receiver_str, _, message = method.rpartition('.')
+ redefine_method(:enqueue) do |method, *args|
+ receiver_str, _, message = method.rpartition(".")
receiver = eval(receiver_str)
receiver.send(message, *args)
end
- def enqueue_in(seconds, method, *args)
- receiver_str, _, message = method.rpartition('.')
+ redefine_method(:enqueue_in) do |seconds, method, *args|
+ receiver_str, _, message = method.rpartition(".")
receiver = eval(receiver_str)
receiver.send(message, *args)
end
- def enqueue_at(not_before, method, *args)
- receiver_str, _, message = method.rpartition('.')
+ redefine_method(:enqueue_at) do |not_before, method, *args|
+ receiver_str, _, message = method.rpartition(".")
receiver = eval(receiver_str)
receiver.send(message, *args)
end