Contents

require 'simpleworker'

redis      = Redis.new
task_queue = SimpleWorker::TaskQueue.new(redis, 'my_hostname', ENV['JOBID'])

task_queue.fire_start

task_queue.each_task do |task|
  task_queue.fire_log_message "Do Task: #{task}"
end

task_queue.fire_stop

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
simpleworker-0.1.1	examples/worker.rb
simpleworker-0.1.0	examples/worker.rb