consumer.py 文件源码

def __init__(self, broker_url, queue_name, fetch_count=10):
        """??????

        Args:
            broker_url (string): broker??
            queue_name (string): ???????
            fetch_count (int): ???????
        """
        self.queue_name = queue_name
        self.broker_url = broker_url
        self.fetch_count = fetch_count

        self.connection = Connection(broker_url)
        self.queue = Queue(queue_name)