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