lib/tasks/insque.rake in insque-0.3.3 vs lib/tasks/insque.rake in insque-0.3.4
- old
+ new
@@ -1,9 +1,9 @@
namespace :insque do
desc 'Starts insque listener and janitor'
task :run => :environment do
trap('TERM') { puts "SIGTERM"; exit 0 }
- threads = {}
+ threads = []
threads << Thread.new() { Insque.listen }
threads << Thread.new() { Insque.janitor }
threads.each {|t| t.join }
end