Contents

class Resque::Pool

  class PooledWorker < ::Resque::Worker

    def initialize(*args)
      @pool_master_pid = Process.pid
      super
    end

    def pool_master_has_gone_away?
      @pool_master_pid && @pool_master_pid != Process.ppid
    end

    # override +shutdown?+ method
    def shutdown?
      super || pool_master_has_gone_away?
    end

  end

end

Version data entries

10 entries across 10 versions & 2 rubygems

Version	Path
vitobotta-resque-pool-0.3.2.dev	lib/resque/pool/pooled_worker.rb
vitobotta-resque-pool-0.3.1.dev	lib/resque/pool/pooled_worker.rb
vitobotta-resque-pool-0.3.0.dev	lib/resque/pool/pooled_worker.rb
resque-pool-0.3.0.beta.1	lib/resque/pool/pooled_worker.rb
resque-pool-0.2.0	lib/resque/pool/pooled_worker.rb
resque-pool-0.1.0	lib/resque/pool/pooled_worker.rb
resque-pool-0.0.12.1.alpha	lib/resque/pool/pooled_worker.rb
resque-pool-0.0.12.0.alpha	lib/resque/pool/pooled_worker.rb
resque-pool-0.0.10.0	lib/resque/pool/pooled_worker.rb
resque-pool-0.0.9	lib/resque/pool/pooled_worker.rb