test/worker_pool_test.rb in larva-0.6.4 vs test/worker_pool_test.rb in larva-0.7.0
- old
+ new
@@ -4,28 +4,24 @@
class WorkerPoolTest < Minitest::Test
def test_should_complete_for_no_processors
WorkerPool.start({})
end
- def test_process_logs_start_message
+ def test_process_logs_start_and_end_messages
Propono.config.logger.stubs(:info)
- Propono.config.logger.expects(:info).with("Starting threads.")
+ Propono.config.logger.expects(:info).with("Starting 0 threads.")
+ Propono.config.logger.expects(:info).with("0 threads started.")
WorkerPool.start({})
end
- def test_process_logs_end_message
- Propono.config.logger.stubs(:info)
- Propono.config.logger.expects(:info).with("Threads Started.")
- WorkerPool.start({})
- end
-
def test_start_worker_logs_exception
Larva::Listener.expects(:listen).raises(RuntimeError)
Propono.config.logger.expects(:error).with do |error|
error.start_with?("Unexpected listener termination:")
end
- Propono.config.logger.expects(:error).with('Some threads have died')
- WorkerPool.start({nil => nil})
+ Propono.config.logger.expects(:error).with('Listener for qux was dead')
+ Propono.config.logger.expects(:error).with('Some threads have died:')
+ WorkerPool.start({'qux' => nil})
end
def test_listen_is_called_correctly
topic_name = "Foo"
processor = mock