Gist for Kthxbye readme

kthxbye_job.rb

# dummy job class
class MyJob
  def self.perform(data)
    puts "Do something with #{data}"
    data.gsub(/hello/i, "Goodbye")
  end
end

# setup options, then connect
Kthxbye::Config.setup(:redis_server => 'localhost', :redis_port => 8080)
Kthxbye.connect

# each enqueued job returns a unique id to poll with
unique_id = Kthxbye.enqueue("jobs", MyJob, "Hello World")

# ... code code code ...

# polls queue every 5 seconds
computed_value = Kthxbye.poll("jobs", unique_id, 5)

kthxbye_worker.rb

# inits with queue
worker = Kthxbye::Worker.new("jobs")

# connects to queue and runs jobs found there
worker.run