'Start the RPC loop to let the plugin communicate with agents.'

@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)
    self.conn.create_consumer(topics.REPORTS, [agents_db.AgentExtRpcCallback()], fanout=False)
    return self.conn.consume_in_threads()
