(self, logger, warn)
| 475 | @patch('celery.worker.consumer.consumer.warn') |
| 476 | @patch('celery.worker.consumer.consumer.logger') |
| 477 | def test_receieve_message_ack_raises(self, logger, warn): |
| 478 | c = self.LoopConsumer() |
| 479 | c.blueprint.state = RUN |
| 480 | channel = Mock(name='channel') |
| 481 | m = self.create_task_message( |
| 482 | channel, self.foo_task.name, |
| 483 | args=[2, 4, 8], kwargs={}, |
| 484 | ) |
| 485 | m.headers = None |
| 486 | |
| 487 | c.update_strategies() |
| 488 | c.connection_errors = (socket.error,) |
| 489 | m.reject = Mock() |
| 490 | m.reject.side_effect = socket.error('foo') |
| 491 | callback = self._get_on_message(c) |
| 492 | assert not callback(m) |
| 493 | warn.assert_called() |
| 494 | with pytest.raises(Empty): |
| 495 | self.buffer.get_nowait() |
| 496 | assert self.timer.empty() |
| 497 | m.reject_log_error.assert_called_with(logger, c.connection_errors) |
| 498 | |
| 499 | def test_receive_message_eta(self): |
| 500 | if os.environ.get('C_DEBUG_TEST'): |
nothing calls this directly
no test coverage detected