Contents

require 'resque/worker'

class Resque::Pool
  module PooledWorker
    def shutdown_with_pool
      shutdown_without_pool || Process.ppid == 1
    end

    def self.included(base)
      base.instance_eval do
        alias_method :shutdown_without_pool, :shutdown?
        alias_method :shutdown?, :shutdown_with_pool
      end
    end

  end
end

Resque::Worker.class_eval do
  include Resque::Pool::PooledWorker
end

Version data entries

6 entries across 6 versions & 3 rubygems

Version	Path
resque-pool-0.4.0	lib/resque/pool/pooled_worker.rb
resque-pool-diet-0.3.1	lib/resque/pool/pooled_worker.rb
resque-pool-vinted-0.4.0.rc1	lib/resque/pool/pooled_worker.rb
resque-pool-0.4.0.rc2	lib/resque/pool/pooled_worker.rb
resque-pool-0.4.0.rc1	lib/resque/pool/pooled_worker.rb
resque-pool-0.3.0	lib/resque/pool/pooled_worker.rb