Contents

require "rubygems"
require "keen"

storage_handler = Keen::Client.create_new_storage_handler(:redis)

count = storage_handler.count_active_queue
puts "we have this many jobs: #{count}"

worker = Keen::Async::Worker.new(storage_handler)
results = worker.process_queue

puts results

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
keen-0.2.0	send.rb
keen-0.1.12	send.rb
keen-0.1.11	send.rb
keen-0.1.10	send.rb
keen-0.1.9	send.rb
keen-0.1.8	send.rb
keen-0.1.7	send.rb
keen-0.1.6	send.rb
keen-0.1.5	send.rb
keen-0.1.4	send.rb
keen-0.1.3	send.rb
keen-0.1.0	send.rb