Implemented queue_classic adapter

1 files changed, 20 insertions, 0 deletions

diff --git a/lib/active_job/queue_adapters/queue_classic_adapter.rb b/lib/active_job/queue_adapters/queue_classic_adapter.rb
new file mode 100644
index 0000000000..e3392a646e
--- /dev/null
+++ b/lib/active_job/queue_adapters/queue_classic_adapter.rb
@@ -0,0 +1,20 @@
+require 'queue_classic'
+
+module ActiveJob
+  module QueueAdapters
+    class QueueClassicAdapter
+      class << self
+        def queue(job, *args)
+          qc_queue = QC::Queue.new(job.queue_name)
+          qc_queue.enqueue("ActiveJob::QueueAdapters::QueueClassicAdapter::JobWrapper.perform", job, *args)
+        end
+      end
+
+      class JobWrapper
+        def self.perform(job, *args)
+          job.new.perform *Parameters.deserialize(args)
+        end
+      end
+    end
+  end
+end