BusinessObjectDefinitionServiceImpl.java 文件源码

@Override
@Async
public Future<Void> indexValidateAllBusinessObjectDefinitions(String indexName)
{
    final String documentType = configurationHelper.getProperty(ConfigurationValue.ELASTICSEARCH_BDEF_DOCUMENT_TYPE, String.class);

    // Get a list of all business object definitions
    final List<BusinessObjectDefinitionEntity> businessObjectDefinitionEntityList =
        Collections.unmodifiableList(businessObjectDefinitionDao.getAllBusinessObjectDefinitions());

    // Remove any index documents that are not in the database
    removeAnyIndexDocumentsThatAreNotInBusinessObjectsDefinitionsList(indexName, documentType, businessObjectDefinitionEntityList);

    // Validate all Business Object Definitions
    businessObjectDefinitionHelper.executeFunctionForBusinessObjectDefinitionEntities(indexName, documentType, businessObjectDefinitionEntityList,
        indexFunctionsDao::validateDocumentIndex);

    // Return an AsyncResult so callers will know the future is "done". They can call "isDone" to know when this method has completed and they
    // can call "get" to see if any exceptions were thrown.
    return new AsyncResult<>(null);
}