server.py 文件源码

def get_consumers(self, Consumer, channel):
        consumers = [
            self._create_service_queues(self.services, Consumer, channel),
            self._create_fanout_exchange(Consumer, channel)
        ]
        return consumers