Contents

require 'rubygems'
#require 'gearman'
require '../lib/gearman'

Gearman::Util.debug = true

servers = ['localhost:4730', 'localhost:4731']
w = Gearman::Worker.new(servers)

# Add a handler for a "sleep" function that takes a single argument, the
# number of seconds to sleep before reporting success.
w.add_ability('sleep') do |data,job|
 seconds = data
 (1..seconds.to_i).each do |i|
   sleep 1
   Gearman::Util.logger.info i
   # Report our progress to the job server every second.
   job.report_status(i, seconds)
 end
 # Report success.
 true
end

# Trap signals while is working
%w(HUP USR1 ALRM TERM).each do |signal|
  trap(signal) do
    puts "Received signal #{signal} - setting worker_enabled to false. Worker status is [#{w.status}]"
    w.worker_enabled = false
    if w.status == :waiting
      trap(signal, "DEFAULT")
      Process.kill( signal, $$ )
    end
  end
end

loop { w.work or break }

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
gearman-ruby-3.0.8	examples/worker_signals.rb
gearman-ruby-3.0.7	examples/worker_signals.rb
gearman-ruby-3.0.6	examples/worker_signals.rb
gearman-ruby-3.0.4	examples/worker_signals.rb
gearman-ruby-3.0.3	examples/worker_signals.rb
gearman-ruby-3.0.2	examples/worker_signals.rb
gearman-ruby-3.0.1	examples/worker_signals.rb