aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/job_wrappers
diff options
context:
space:
mode:
Diffstat (limited to 'lib/active_job/job_wrappers')
-rw-r--r--lib/active_job/job_wrappers/delayed_job_wrapper.rb9
-rw-r--r--lib/active_job/job_wrappers/resque_wrapper.rb29
-rw-r--r--lib/active_job/job_wrappers/sidekiq_wrapper.rb13
-rw-r--r--lib/active_job/job_wrappers/sucker_punch_wrapper.rb11
4 files changed, 0 insertions, 62 deletions
diff --git a/lib/active_job/job_wrappers/delayed_job_wrapper.rb b/lib/active_job/job_wrappers/delayed_job_wrapper.rb
deleted file mode 100644
index 0868d7b570..0000000000
--- a/lib/active_job/job_wrappers/delayed_job_wrapper.rb
+++ /dev/null
@@ -1,9 +0,0 @@
-module ActiveJob
- module JobWrappers
- class DelayedJobWrapper
- def perform(job, *args)
- job.perform(*ActiveJob::Parameters.deserialize(args))
- end
- end
- end
-end
diff --git a/lib/active_job/job_wrappers/resque_wrapper.rb b/lib/active_job/job_wrappers/resque_wrapper.rb
deleted file mode 100644
index 68d9b252ba..0000000000
--- a/lib/active_job/job_wrappers/resque_wrapper.rb
+++ /dev/null
@@ -1,29 +0,0 @@
-require 'resque'
-
-require 'active_support/core_ext/enumerable'
-require 'active_support/core_ext/array/access'
-
-module ActiveJob
- module JobWrappers
- class ResqueWrapper
- class << self
- def wrap(job, args)
- [ new(job), *args.prepend(job) ]
- end
-
- def perform(job_name, *args)
- job_name.constantize.perform(*ActiveJob::Parameters.deserialize(args))
- end
- end
-
-
- def initialize(job)
- @queue = job.queue_name
- end
-
- def to_s
- self.class.to_s
- end
- end
- end
-end
diff --git a/lib/active_job/job_wrappers/sidekiq_wrapper.rb b/lib/active_job/job_wrappers/sidekiq_wrapper.rb
deleted file mode 100644
index e1332b0210..0000000000
--- a/lib/active_job/job_wrappers/sidekiq_wrapper.rb
+++ /dev/null
@@ -1,13 +0,0 @@
-require 'active_job/parameters'
-
-module ActiveJob
- module JobWrappers
- class SidekiqWrapper
- include Sidekiq::Worker
-
- def perform(job_name, *args)
- job_name.constantize.perform(*ActiveJob::Parameters.deserialize(args))
- end
- end
- end
-end
diff --git a/lib/active_job/job_wrappers/sucker_punch_wrapper.rb b/lib/active_job/job_wrappers/sucker_punch_wrapper.rb
deleted file mode 100644
index 7e9960b44f..0000000000
--- a/lib/active_job/job_wrappers/sucker_punch_wrapper.rb
+++ /dev/null
@@ -1,11 +0,0 @@
-module ActiveJob
- module JobWrappers
- class SuckerPunchWrapper
- include SuckerPunch::Job
-
- def perform(job_name, *args)
- job_name.perform(*ActiveJob::Parameters.deserialize(args))
- end
- end
- end
-end