Contents

require 'resque/worker'

class Resque::Pool
  module PooledWorker

    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

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
resque-pool-0.3.0.beta.2	lib/resque/pool/pooled_worker.rb