diff options
Diffstat (limited to 'lib/active_job/job_wrappers')
-rw-r--r-- | lib/active_job/job_wrappers/delayed_job_wrapper.rb | 9 | ||||
-rw-r--r-- | lib/active_job/job_wrappers/resque_wrapper.rb | 29 | ||||
-rw-r--r-- | lib/active_job/job_wrappers/sidekiq_wrapper.rb | 13 | ||||
-rw-r--r-- | lib/active_job/job_wrappers/sucker_punch_wrapper.rb | 11 |
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 |