require 'simpleworker'

tasks = ['first', 'second', 'third']
redis = Redis.new

# create a remote worker
ssh_worker = SimpleWorker::SshWorker.new(
  :user    => 'jesg'
  :host    => 'localhost',
  :cmd     => 'ruby -s worker.rb',
  # rsync will wipe out existing files in ~/my_unused_dir
  :dirname => 'my_unused_dir')

# create a local worker
local_worker = SimpleWorker::LocalWorker.new("ruby", "worker.rb")

runner = SimpleWorker::Runner.new(redis, tasks,
  :namespace    => 'foobar',                    # redis key prefix
  :notify       => [local_worker, ssh_worker],  # listeners that implement AbstractListener
  :max_retries  => 1,                           # max times expired tasks will be retried
  :timeout      => 60,                          # timout in seconds if inactive
  :task_timeout => 14,                          # max time for a task before it expires
  :interval     => 2)                           # interval at which to pull redis event log for the job in seconds

runner.run

require 'simpleworker'

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

task_queue.fire_start

task_queue.each_task do |task|
  task_queue.fire_log_message(task)
end

task_queue.fire_stop