lib/stalker.rb in stalker-0.2.4 vs lib/stalker.rb in stalker-0.2.5
- old
+ new
@@ -27,11 +27,14 @@
raise(NoSuchJob, job) unless @@handlers[job]
end
log "Working #{jobs.size} jobs: [ #{jobs.join(' ')} ]"
- beanstalk.list_tubes_watched.each { |tube| beanstalk.ignore(tube) }
jobs.each { |job| beanstalk.watch(job) }
+
+ beanstalk.list_tubes_watched.each do |server, tubes|
+ tubes.each { |tube| beanstalk.ignore(tube) unless jobs.include?(tube) }
+ end
loop do
work_one_job
end
rescue Beanstalk::NotConnected => e