Class PlatformReindexServiceImpl
java.lang.Object
com.flowable.platform.service.index.PlatformReindexServiceImpl
- All Implemented Interfaces:
PlatformReindexService
,SynchronousPlatformReindexService
public class PlatformReindexServiceImpl extends java.lang.Object implements PlatformReindexService, SynchronousPlatformReindexService
-
Field Summary
Fields Modifier and Type Field Description protected ActivityIndexingScheduler
activityIndexingScheduler
protected CaseInstanceIndexingScheduler
caseInstanceIndexingScheduler
protected org.flowable.cmmn.engine.CmmnEngine
cmmnEngine
protected ContentItemIndexingScheduler
contentItemIndexingScheduler
protected com.flowable.core.content.api.CoreContentService
contentService
protected PlanItemInstanceIndexingScheduler
planItemInstanceIndexingScheduler
protected org.flowable.engine.ProcessEngine
processEngine
protected ProcessInstanceIndexingScheduler
processInstanceIndexingScheduler
protected ReindexManager
reindexManager
protected TaskIndexingScheduler
taskIndexingScheduler
protected WorkIndexingScheduler
workIndexingScheduler
-
Constructor Summary
Constructors Constructor Description PlatformReindexServiceImpl(org.flowable.engine.ProcessEngine processEngine, org.flowable.cmmn.engine.CmmnEngine cmmnEngine, com.flowable.core.content.api.CoreContentService contentService, ReindexManager reindexManager, ProcessInstanceIndexingScheduler processInstanceIndexingScheduler, CaseInstanceIndexingScheduler caseInstanceIndexingScheduler, TaskIndexingScheduler taskIndexingScheduler, PlanItemInstanceIndexingScheduler planItemInstanceIndexingScheduler, WorkIndexingScheduler workIndexingScheduler, ActivityIndexingScheduler activityIndexingScheduler, ContentItemIndexingScheduler contentItemIndexingScheduler)
-
Method Summary
Modifier and Type Method Description void
reindexActivities()
Reindex all process activity instances in the database.void
reindexActivity(java.lang.String activityInstanceId)
Reindex one activity instance.void
reindexCaseInstance(java.lang.String caseInstanceId)
Reindex one case instance.void
reindexCaseInstances()
Reindex all case instances in the database.void
reindexContentItem(java.lang.String contentItemId)
Reindex one content item.void
reindexContentItems()
Reindex all content items in the database.void
reindexPlanItemInstance(java.lang.String planItemInstanceId)
Reindex one plan item instance.void
reindexPlanItemInstances()
Reindex all plan item instances in the database.void
reindexProcessInstance(java.lang.String processInstanceId)
Reindex one process instance.void
reindexProcessInstances()
Reindex all process instances in the database.void
reindexTask(java.lang.String taskId)
Reindex one task.void
reindexTasks()
Reindex all tasks in the database.void
reindexWork()
Reindex all work instances (i.e.void
synchronousReindexActivities()
void
synchronousReindexActivity(java.lang.String activityInstanceId)
void
synchronousReindexCaseInstance(java.lang.String caseInstanceId)
void
synchronousReindexCaseInstances()
void
synchronousReindexContentItem(java.lang.String contentItemId)
void
synchronousReindexContentItems()
void
synchronousReindexPlanItemInstance(java.lang.String planItemInstanceId)
void
synchronousReindexPlanItemInstances()
void
synchronousReindexProcessInstance(java.lang.String processInstanceId)
void
synchronousReindexProcessInstances()
void
synchronousReindexTask(java.lang.String taskId)
void
synchronousReindexTasks()
void
synchronousReindexWork()
void
synchronousReindexWorkCaseInstance(java.lang.String caseInstanceId)
void
synchronousReindexWorkProcessInstance(java.lang.String processInstanceId)
-
Field Details
-
processEngine
protected org.flowable.engine.ProcessEngine processEngine -
cmmnEngine
protected org.flowable.cmmn.engine.CmmnEngine cmmnEngine -
contentService
protected com.flowable.core.content.api.CoreContentService contentService -
reindexManager
-
processInstanceIndexingScheduler
-
caseInstanceIndexingScheduler
-
planItemInstanceIndexingScheduler
-
taskIndexingScheduler
-
workIndexingScheduler
-
activityIndexingScheduler
-
contentItemIndexingScheduler
-
-
Constructor Details
-
PlatformReindexServiceImpl
public PlatformReindexServiceImpl(org.flowable.engine.ProcessEngine processEngine, org.flowable.cmmn.engine.CmmnEngine cmmnEngine, com.flowable.core.content.api.CoreContentService contentService, ReindexManager reindexManager, ProcessInstanceIndexingScheduler processInstanceIndexingScheduler, CaseInstanceIndexingScheduler caseInstanceIndexingScheduler, TaskIndexingScheduler taskIndexingScheduler, PlanItemInstanceIndexingScheduler planItemInstanceIndexingScheduler, WorkIndexingScheduler workIndexingScheduler, ActivityIndexingScheduler activityIndexingScheduler, ContentItemIndexingScheduler contentItemIndexingScheduler)
-
-
Method Details
-
reindexProcessInstances
@Async public void reindexProcessInstances()Description copied from interface:PlatformReindexService
Reindex all process instances in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread.- Specified by:
reindexProcessInstances
in interfacePlatformReindexService
-
synchronousReindexProcessInstances
public void synchronousReindexProcessInstances()- Specified by:
synchronousReindexProcessInstances
in interfaceSynchronousPlatformReindexService
-
reindexProcessInstance
@Async public void reindexProcessInstance(java.lang.String processInstanceId)Description copied from interface:PlatformReindexService
Reindex one process instance. This method, contrary toPlatformReindexService.reindexProcessInstance(String)
runs synchronously. If the process instance is a root process instance, data changes will be propagated to all children.- Specified by:
reindexProcessInstance
in interfacePlatformReindexService
-
synchronousReindexProcessInstance
public void synchronousReindexProcessInstance(java.lang.String processInstanceId)- Specified by:
synchronousReindexProcessInstance
in interfaceSynchronousPlatformReindexService
-
reindexCaseInstances
@Async public void reindexCaseInstances()Description copied from interface:PlatformReindexService
Reindex all case instances in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread.- Specified by:
reindexCaseInstances
in interfacePlatformReindexService
-
synchronousReindexCaseInstances
public void synchronousReindexCaseInstances()- Specified by:
synchronousReindexCaseInstances
in interfaceSynchronousPlatformReindexService
-
reindexCaseInstance
@Async public void reindexCaseInstance(java.lang.String caseInstanceId)Description copied from interface:PlatformReindexService
Reindex one case instance. This method, contrary toPlatformReindexService.reindexCaseInstance(String)
runs synchronously. If the process instance is a root process instance, data changes will be propagated to all children.- Specified by:
reindexCaseInstance
in interfacePlatformReindexService
-
synchronousReindexCaseInstance
public void synchronousReindexCaseInstance(java.lang.String caseInstanceId)- Specified by:
synchronousReindexCaseInstance
in interfaceSynchronousPlatformReindexService
-
reindexPlanItemInstances
@Async public void reindexPlanItemInstances()Description copied from interface:PlatformReindexService
Reindex all plan item instances in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread.- Specified by:
reindexPlanItemInstances
in interfacePlatformReindexService
-
synchronousReindexPlanItemInstances
public void synchronousReindexPlanItemInstances()- Specified by:
synchronousReindexPlanItemInstances
in interfaceSynchronousPlatformReindexService
-
reindexPlanItemInstance
@Async public void reindexPlanItemInstance(java.lang.String planItemInstanceId)Description copied from interface:PlatformReindexService
Reindex one plan item instance. This method, contrary toPlatformReindexService.reindexCaseInstance(String)
runs synchronously.- Specified by:
reindexPlanItemInstance
in interfacePlatformReindexService
-
synchronousReindexPlanItemInstance
public void synchronousReindexPlanItemInstance(java.lang.String planItemInstanceId)- Specified by:
synchronousReindexPlanItemInstance
in interfaceSynchronousPlatformReindexService
-
reindexTasks
@Async public void reindexTasks()Description copied from interface:PlatformReindexService
Reindex all tasks in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread.- Specified by:
reindexTasks
in interfacePlatformReindexService
-
synchronousReindexTasks
public void synchronousReindexTasks()- Specified by:
synchronousReindexTasks
in interfaceSynchronousPlatformReindexService
-
reindexTask
@Async public void reindexTask(java.lang.String taskId)Description copied from interface:PlatformReindexService
Reindex one task. This method, contrary toPlatformReindexService.reindexCaseInstance(String)
runs synchronously.- Specified by:
reindexTask
in interfacePlatformReindexService
-
synchronousReindexTask
public void synchronousReindexTask(java.lang.String taskId)- Specified by:
synchronousReindexTask
in interfaceSynchronousPlatformReindexService
-
reindexWork
@Async public void reindexWork()Description copied from interface:PlatformReindexService
Reindex all work instances (i.e. root process and case instances) in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread. There is no 'single work instance' reindex method. This is done by callingPlatformReindexService.reindexProcessInstance(String)
orPlatformReindexService.reindexCaseInstance(String)
, which will update the work index if the instance is a root instance.- Specified by:
reindexWork
in interfacePlatformReindexService
-
synchronousReindexWork
public void synchronousReindexWork()- Specified by:
synchronousReindexWork
in interfaceSynchronousPlatformReindexService
-
synchronousReindexWorkProcessInstance
public void synchronousReindexWorkProcessInstance(java.lang.String processInstanceId)- Specified by:
synchronousReindexWorkProcessInstance
in interfaceSynchronousPlatformReindexService
-
synchronousReindexWorkCaseInstance
public void synchronousReindexWorkCaseInstance(java.lang.String caseInstanceId)- Specified by:
synchronousReindexWorkCaseInstance
in interfaceSynchronousPlatformReindexService
-
reindexActivities
@Async public void reindexActivities()Description copied from interface:PlatformReindexService
Reindex all process activity instances in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread.- Specified by:
reindexActivities
in interfacePlatformReindexService
-
synchronousReindexActivities
public void synchronousReindexActivities()- Specified by:
synchronousReindexActivities
in interfaceSynchronousPlatformReindexService
-
reindexActivity
@Async public void reindexActivity(java.lang.String activityInstanceId)Description copied from interface:PlatformReindexService
Reindex one activity instance. This method, contrary toPlatformReindexService.reindexCaseInstance(String)
runs synchronously.- Specified by:
reindexActivity
in interfacePlatformReindexService
-
synchronousReindexActivity
public void synchronousReindexActivity(java.lang.String activityInstanceId)- Specified by:
synchronousReindexActivity
in interfaceSynchronousPlatformReindexService
-
reindexContentItems
@Async public void reindexContentItems()Description copied from interface:PlatformReindexService
Reindex all content items in the database. A new index will be created, filled with the data and the alias is swapped to this new index at the end of the operation This method will return immediately, but the indexing will happen asynchronously on a background thread.- Specified by:
reindexContentItems
in interfacePlatformReindexService
-
synchronousReindexContentItems
public void synchronousReindexContentItems()- Specified by:
synchronousReindexContentItems
in interfaceSynchronousPlatformReindexService
-
reindexContentItem
@Async public void reindexContentItem(java.lang.String contentItemId)Description copied from interface:PlatformReindexService
Reindex one content item. This method, contrary toPlatformReindexService.reindexCaseInstance(String)
runs synchronously.- Specified by:
reindexContentItem
in interfacePlatformReindexService
-
synchronousReindexContentItem
public void synchronousReindexContentItem(java.lang.String contentItemId)- Specified by:
synchronousReindexContentItem
in interfaceSynchronousPlatformReindexService
-