test_unit.py 文件源码

def test_routes_to_all_consumer_queues(self):
        await self.GIVEN_ConsumerRegistered(queue_name="fake_consumer_queue1",
                                      exchange_name="fake_exch",
                                      exchange_type="fanout",
                                      routing_keys="",
                                      callback = self.fake_callback)

        await self.GIVEN_ConsumerRegistered(queue_name="fake_consumer_queue2",
                                      exchange_name="fake_exch",
                                      exchange_type="fanout",
                                      routing_keys="",
                                      callback = self.fake_callback2)

        await self.GIVEN_MessagePublished(exchange_name="fake_exch",
                                    msg="fake_msg",
                                    routing_key="")

        await self.WHEN_ProcessEventsNTimes(1)

        self.THEN_CallbackReceivesMessage("fake_msg")
        self.THEN_Callback2ReceivesMessage("fake_msg")


# @unittest.skip("skipped")