rabbitmq.py 文件源码

def __init__(self, config):
        self.config = config
        self.message_ttl = str(self.config.market_expiration_time * 1000)
        self.report_queue = self.config.report_queue
        self.params = pika.URLParameters(self.config.amqp_url)
        self.queue_args = self.config.queue_args
        self._connection = None
        self._channel = None
        ##app_config = configparser.ConfigParser()
        ##app_config.read('config')
        self.key = config.creds['settings']['aes_key']