Created

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist

Gist for Kthxbye readme

View kthxbye_job.rb
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
# 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)
View kthxbye_job.rb
1 2 3 4 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
Something went wrong with that request. Please try again.