Contents

module Resqutils
  # Can be queued to kill a worker.  By default, will be queued to the 'worker_killer_job' queue, however
  # you can specify RESQUTILS_WORKER_KILLER_JOB_QUEUE in the environment to set an override.  Of course, you can always
  # forcibly enqueue it as needed.
  class WorkerKillerJob
    def self.queue
      @queue ||= begin
                   queue = String(ENV["RESQUTILS_WORKER_KILLER_JOB_QUEUE"]).strip
                   queue.length == 0 ? :worker_killer_job : queue
                 end
    end
    def self.perform(worker_id)
      Resque.workers.detect { |_| _.id == worker_id }.unregister_worker
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
resqutils-1.0.0	lib/resqutils/worker_killer_job.rb