Searched refs:_test_terminating_queue (Results 1 – 1 of 1) sorted by relevance
165 def _test_terminating_queue(self, exception, termination_message): member in QueueEngineTest179 self._test_terminating_queue(KeyboardInterrupt(), "User terminated queue.")180 self._test_terminating_queue(TerminateQueue(), "TerminateQueue exception received.")