Package com.flowable.platform.service.index

Class PlatformReindexServiceImpl

java.lang.Object

com.flowable.platform.service.index.PlatformReindexServiceImpl

All Implemented Interfaces:

PlatformReindexService, SynchronousPlatformReindexService

public class PlatformReindexServiceImpl
extends Object
implements PlatformReindexService, SynchronousPlatformReindexService

Field Summary

Fields

Modifier and Type	Field	Description
protected ActivityIndexingScheduler	activityIndexingScheduler
protected CaseInstanceIndexingScheduler	caseInstanceIndexingScheduler
protected CmmnEngine	cmmnEngine
protected ContentItemIndexingScheduler	contentItemIndexingScheduler
protected CoreContentService	contentService
protected Collection<String>	enabledIndices
protected PlanItemInstanceIndexingScheduler	planItemInstanceIndexingScheduler
protected ProcessEngine	processEngine
protected ProcessInstanceIndexingScheduler	processInstanceIndexingScheduler
protected ReindexManager	reindexManager
protected TaskIndexingScheduler	taskIndexingScheduler
protected WorkIndexingScheduler	workIndexingScheduler

Constructor Summary

Constructors

Constructor

Description

PlatformReindexServiceImpl(ProcessEngine processEngine, CmmnEngine cmmnEngine, CoreContentService contentService, ReindexManager reindexManager, ProcessInstanceIndexingScheduler processInstanceIndexingScheduler, CaseInstanceIndexingScheduler caseInstanceIndexingScheduler, TaskIndexingScheduler taskIndexingScheduler, PlanItemInstanceIndexingScheduler planItemInstanceIndexingScheduler, WorkIndexingScheduler workIndexingScheduler, ActivityIndexingScheduler activityIndexingScheduler, ContentItemIndexingScheduler contentItemIndexingScheduler, Collection<String> enabledIndices)

Method Summary

Modifier and Type	Method	Description
boolean	isIndexingDisabled(String index)	Checks if indexing is disabled for the provided index.
void	reindexActivities()	Reindex all process activity instances in the database.
void	reindexActivity(String activityInstanceId)	Reindex one activity instance.
void	reindexCaseInstance(String caseInstanceId)	Reindex one case instance.
void	reindexCaseInstances()	Reindex all case instances in the database.
void	reindexContentItem(String contentItemId)	Reindex one content item.
void	reindexContentItems()	Reindex all content items in the database.
void	reindexPlanItemInstance(String planItemInstanceId)	Reindex one plan item instance.
void	reindexPlanItemInstances()	Reindex all plan item instances in the database.
void	reindexProcessInstance(String processInstanceId)	Reindex one process instance.
void	reindexProcessInstances()	Reindex all process instances in the database.
void	reindexTask(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(String activityInstanceId)
void	synchronousReindexCaseInstance(String caseInstanceId)
void	synchronousReindexCaseInstances()
void	synchronousReindexContentItem(String contentItemId)
void	synchronousReindexContentItems()
void	synchronousReindexPlanItemInstance(String planItemInstanceId)
void	synchronousReindexPlanItemInstances()
void	synchronousReindexProcessInstance(String processInstanceId)
void	synchronousReindexProcessInstances()
void	synchronousReindexTask(String taskId)
void	synchronousReindexTasks()
void	synchronousReindexWork()
void	synchronousReindexWorkCaseInstance(String caseInstanceId)
void	synchronousReindexWorkProcessInstance(String processInstanceId)

Methods inherited from class java.lang.Object

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

Field Details

processEngine

protected ProcessEngine processEngine

cmmnEngine

protected CmmnEngine cmmnEngine

contentService

protected CoreContentService contentService

reindexManager

protected ReindexManager reindexManager

processInstanceIndexingScheduler

protected ProcessInstanceIndexingScheduler processInstanceIndexingScheduler

caseInstanceIndexingScheduler

protected CaseInstanceIndexingScheduler caseInstanceIndexingScheduler

planItemInstanceIndexingScheduler

protected PlanItemInstanceIndexingScheduler planItemInstanceIndexingScheduler

taskIndexingScheduler

protected TaskIndexingScheduler taskIndexingScheduler

workIndexingScheduler

protected WorkIndexingScheduler workIndexingScheduler

activityIndexingScheduler

protected ActivityIndexingScheduler activityIndexingScheduler

contentItemIndexingScheduler

protected ContentItemIndexingScheduler contentItemIndexingScheduler

enabledIndices

protected Collection<String> enabledIndices

Constructor Details

PlatformReindexServiceImpl

public PlatformReindexServiceImpl(ProcessEngine processEngine,
 CmmnEngine cmmnEngine,
 CoreContentService contentService,
 ReindexManager reindexManager,
 ProcessInstanceIndexingScheduler processInstanceIndexingScheduler,
 CaseInstanceIndexingScheduler caseInstanceIndexingScheduler,
 TaskIndexingScheduler taskIndexingScheduler,
 PlanItemInstanceIndexingScheduler planItemInstanceIndexingScheduler,
 WorkIndexingScheduler workIndexingScheduler,
 ActivityIndexingScheduler activityIndexingScheduler,
 ContentItemIndexingScheduler contentItemIndexingScheduler,
 Collection<String> enabledIndices)

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 interface PlatformReindexService

synchronousReindexProcessInstances

public void synchronousReindexProcessInstances()

Specified by:

synchronousReindexProcessInstances in interface SynchronousPlatformReindexService

reindexProcessInstance

@Async
public void reindexProcessInstance(String processInstanceId)

Description copied from interface: PlatformReindexService

Reindex one process instance. This method, contrary to PlatformReindexService.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 interface PlatformReindexService

synchronousReindexProcessInstance

public void synchronousReindexProcessInstance(String processInstanceId)

Specified by:

synchronousReindexProcessInstance in interface SynchronousPlatformReindexService

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 interface PlatformReindexService

synchronousReindexCaseInstances

public void synchronousReindexCaseInstances()

Specified by:

synchronousReindexCaseInstances in interface SynchronousPlatformReindexService

reindexCaseInstance

@Async
public void reindexCaseInstance(String caseInstanceId)

Description copied from interface: PlatformReindexService

Reindex one case instance. This method, contrary to PlatformReindexService.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 interface PlatformReindexService

synchronousReindexCaseInstance

public void synchronousReindexCaseInstance(String caseInstanceId)

Specified by:

synchronousReindexCaseInstance in interface SynchronousPlatformReindexService

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 interface PlatformReindexService

synchronousReindexPlanItemInstances

public void synchronousReindexPlanItemInstances()

Specified by:

synchronousReindexPlanItemInstances in interface SynchronousPlatformReindexService

reindexPlanItemInstance

@Async
public void reindexPlanItemInstance(String planItemInstanceId)

Description copied from interface: PlatformReindexService

Reindex one plan item instance. This method, contrary to PlatformReindexService.reindexCaseInstance(String) runs synchronously.

Specified by:

reindexPlanItemInstance in interface PlatformReindexService

synchronousReindexPlanItemInstance

public void synchronousReindexPlanItemInstance(String planItemInstanceId)

Specified by:

synchronousReindexPlanItemInstance in interface SynchronousPlatformReindexService

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 interface PlatformReindexService

synchronousReindexTasks

public void synchronousReindexTasks()

Specified by:

synchronousReindexTasks in interface SynchronousPlatformReindexService

reindexTask

@Async
public void reindexTask(String taskId)

Description copied from interface: PlatformReindexService

Reindex one task. This method, contrary to PlatformReindexService.reindexCaseInstance(String) runs synchronously.

Specified by:

reindexTask in interface PlatformReindexService

synchronousReindexTask

public void synchronousReindexTask(String taskId)

Specified by:

synchronousReindexTask in interface SynchronousPlatformReindexService

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 calling PlatformReindexService.reindexProcessInstance(String) or PlatformReindexService.reindexCaseInstance(String), which will update the work index if the instance is a root instance.

Specified by:

reindexWork in interface PlatformReindexService

isIndexingDisabled

public boolean isIndexingDisabled(String index)

Description copied from interface: PlatformReindexService

Checks if indexing is disabled for the provided index. This method runs synchronously.

Specified by:

isIndexingDisabled in interface PlatformReindexService

Returns:

true if the indexing is disabled.

synchronousReindexWork

public void synchronousReindexWork()

Specified by:

synchronousReindexWork in interface SynchronousPlatformReindexService

synchronousReindexWorkProcessInstance

public void synchronousReindexWorkProcessInstance(String processInstanceId)

Specified by:

synchronousReindexWorkProcessInstance in interface SynchronousPlatformReindexService

synchronousReindexWorkCaseInstance

public void synchronousReindexWorkCaseInstance(String caseInstanceId)

Specified by:

synchronousReindexWorkCaseInstance in interface SynchronousPlatformReindexService

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 interface PlatformReindexService

synchronousReindexActivities

public void synchronousReindexActivities()

Specified by:

synchronousReindexActivities in interface SynchronousPlatformReindexService

reindexActivity

@Async
public void reindexActivity(String activityInstanceId)

Description copied from interface: PlatformReindexService

Reindex one activity instance. This method, contrary to PlatformReindexService.reindexCaseInstance(String) runs synchronously.

Specified by:

reindexActivity in interface PlatformReindexService

synchronousReindexActivity

public void synchronousReindexActivity(String activityInstanceId)

Specified by:

synchronousReindexActivity in interface SynchronousPlatformReindexService

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 interface PlatformReindexService

synchronousReindexContentItems

public void synchronousReindexContentItems()

Specified by:

synchronousReindexContentItems in interface SynchronousPlatformReindexService

reindexContentItem

@Async
public void reindexContentItem(String contentItemId)

Description copied from interface: PlatformReindexService

Reindex one content item. This method, contrary to PlatformReindexService.reindexCaseInstance(String) runs synchronously.

Specified by:

reindexContentItem in interface PlatformReindexService

synchronousReindexContentItem

public void synchronousReindexContentItem(String contentItemId)

Specified by:

synchronousReindexContentItem in interface SynchronousPlatformReindexService