spec/queues_spec.rb in sidekiq-dynamic-queues-0.5.6 vs spec/queues_spec.rb in sidekiq-dynamic-queues-0.6.0
- old
+ new
@@ -240,21 +240,20 @@
SomeJob.result.should eq [2]
end
it "finds work on dynamic queue that doesn't exist till after sidekiq is waiting for jobs" do
watch_queues(*%w[default])
- manager = run_queues("*", :async => true)
+ launcher = run_queues("*", :async => true)
# give run_queues a chance to block on only the default queue given above
sleep 0.1
enqueue_on("other", SomeJob, 1)
# sidekiq brpop's with a timeout of 1, so we need to wait longer than
# that for it to re-evaluate the dynamic queues
sleep 2
timeout(5) do
- manager.async.stop(:shutdown => true, :timeout => 1)
- manager.wait(:shutdown)
+ launcher.stop
end
SomeJob.result.should eq [1]
end
end