Package com.netgrif.application.engine.elastic.service

Class ReindexingTask

java.lang.Object

com.netgrif.application.engine.elastic.service.ReindexingTask

@Component
@ConditionalOnExpression("\'${spring.data.elasticsearch.reindex}\'!= \'null\'")
public class ReindexingTask
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
ReindexingTask(CaseRepository caseRepository, TaskRepository taskRepository, ElasticCaseRepository elasticCaseRepository, IElasticCaseService elasticCaseService, IElasticTaskService elasticTaskService, IElasticCaseMappingService caseMappingService, IElasticTaskMappingService taskMappingService, IWorkflowService workflowService, int pageSize, java.time.Duration from)

Method Summary

Modifier and Type	Method	Description
void	forceReindexPage(com.querydsl.core.types.Predicate predicate, int page, long numOfPages)
void	reindex()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReindexingTask

@Autowired
public ReindexingTask(CaseRepository caseRepository,
                      TaskRepository taskRepository,
                      ElasticCaseRepository elasticCaseRepository,
                      @Qualifier("reindexingTaskElasticCaseService")
                      IElasticCaseService elasticCaseService,
                      @Qualifier("reindexingTaskElasticTaskService")
                      IElasticTaskService elasticTaskService,
                      IElasticCaseMappingService caseMappingService,
                      IElasticTaskMappingService taskMappingService,
                      IWorkflowService workflowService,
                      @Value("${spring.data.elasticsearch.reindexExecutor.size:20}")
                      int pageSize,
                      @Value("${spring.data.elasticsearch.reindex-from:#{null}}")
                      java.time.Duration from)

Method Detail

reindex

@Scheduled(cron="#{springElasticsearchReindex}")
public void reindex()

forceReindexPage

public void forceReindexPage(com.querydsl.core.types.Predicate predicate,
                             int page,
                             long numOfPages)