1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00

Fix tests

This commit is contained in:
Mike Perham 2015-10-08 21:50:45 -07:00
parent 5e88414ef5
commit 20fecf5e6b
2 changed files with 7 additions and 2 deletions

View file

@ -53,7 +53,7 @@ module Sidekiq
while !@done
process_one
end
@mgr.processor_stopped(self, ex)
@mgr.processor_stopped(self)
rescue Exception => ex
@mgr.processor_died(self, ex)
end

View file

@ -65,6 +65,11 @@ class TestActors < Sidekiq::Test
@cond.signal
end
end
def processor_stopped(inst)
@mutex.synchronize do
@cond.signal
end
end
def options
{ :concurrency => 3, :queues => ['default'] }
end
@ -118,7 +123,7 @@ class TestActors < Sidekiq::Test
b = $count
assert_equal a, b
assert_equal false, p.thread.status
refute mgr.latest_error
refute mgr.latest_error, mgr.latest_error.to_s
end
end
end