diff options
Diffstat (limited to 'activejob/test/support/queue_classic/inline.rb')
-rw-r--r-- | activejob/test/support/queue_classic/inline.rb | 17 |
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 |