def start(self):
        super(RpcWorker, self).start()
        for plugin in self._plugins:
            if hasattr(plugin, self.start_listeners_method):
                try:
                    servers = getattr(plugin, self.start_listeners_method)()
                except __HOLE__:
                    continue
                self._servers.extend(servers)
dataset/ETHPy150Open openstack/neutron/neutron/service.py/RpcWorker.start