test_unit.py 文件源码

def test_callback_is_run(self):
        await self.GIVEN_ConsumerRegistered(queue_name="fake_consumer_queue",
                                      exchange_name="fake_exch",
                                      exchange_type="direct",
                                      routing_keys=["fake_routing_key"],
                                      callback = self.fake_callback)
        await self.GIVEN_MessagePublished(exchange_name="fake_exch",
                                    msg="fake_message",
                                    routing_key="fake_routing_key")
        await self.WHEN_ProcessEventsNTimes(2)

        self.THEN_CallbackReceivesMessage("fake_message")



    # @unittest.skip("skipped")