def __init__(self, exchange_name, broker_url, mode=ASYNC):
"""??????
Args:
exchange_name (string): ????
broker_url (string): ????
mode (int): ??
"""
self.exchange_name = exchange_name
self.broker_url = broker_url
self.mode = mode
self.exchange = Exchange(exchange_name, type='direct')
self.connection = Connection(broker_url)
评论列表
文章目录