@log_helpers.log_method_call
    def start_rpc_listeners(self):
        self._setup_rpc()
        self.topic = topics.PLUGIN
        self.conn = n_rpc.create_connection()
        self.conn.create_consumer(self.topic, self.endpoints, fanout=False)
        self.conn.create_consumer(
            topics.SERVER_RESOURCE_VERSIONS,
            [resources_rpc.ResourcesPushToServerRpcCallback()],
            fanout=True)
        # process state reports despite dedicated rpc workers
        self.conn.create_consumer(topics.REPORTS,
                                  [agents_db.AgentExtRpcCallback()],
                                  fanout=False)
        return self.conn.consume_in_threads()
Returns the user owned_by accounting for the given user.
dataset/ETHPy150Open openstack/neutron/neutron/plugins/ml2/plugin.py/Ml2Plugin.start_rpc_listeners--crossover with--dataset/ETHPy150Open viewfinderco/viewfinder/backend/db/accounting.py/AccountingAccumulator.GetUserOwnedBy