work_frame.py 文件源码

def __init__(self, name=None, service_group_conf=None, app=None, channel="center", lock=False, auri=None):
        # ??name????service_group_conf??service_group??
        if not name:
            if service_group_conf:
                name = get_service_group(service_group_conf).get('service_group')
            if not name:
                raise EnvironmentError('Neither name given nor service_group_conf name given')
        super(WORK_FRAME, self).__init__(name, app=app, channel=channel, auri=auri, lock=lock)
        self.command_q = "{0}-{1}".format(self.name, self.id)
        # frame????,????consumer??20s?????command_q
        self.create_queue(self.command_q, ttl=15, args={'x-expires': 20000})
        self.command_prefix = "skyeye-rpc-{0}.".format(self.name)
        self.join(self.command_q, "{0}*".format(self.command_prefix))
        self.init_command()
        self.command_pool = Pool(100)
        self.service_group_conf = service_group_conf