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