Create a gist now

Instantly share code, notes, and snippets.

Gist for Kthxbye readme
# 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)
# inits with queue
worker = Kthxbye::Worker.new("jobs")
# connects to queue and runs jobs found there
worker.run
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment