Package com.flowable.idm.engine.impl.indexing

Class IdmIndexingSchedulerImpl

java.lang.Object

com.flowable.idm.engine.impl.indexing.IdmIndexingSchedulerImpl

All Implemented Interfaces:

IdmIndexingScheduler

public class IdmIndexingSchedulerImpl
extends Object
implements IdmIndexingScheduler

Field Summary

Fields

Modifier and Type	Field	Description
protected CoreIdmEngineConfiguration	idmEngineConfiguration
protected IndexingService	indexingService
static final String	MAPPING_TYPE_USER
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor	Description
IdmIndexingSchedulerImpl(IndexingService indexingService, com.fasterxml.jackson.databind.ObjectMapper objectMapper, CoreIdmEngineConfiguration idmEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
protected void	addOrReplaceHistoricData(com.fasterxml.jackson.databind.node.ObjectNode dataNode, String tenantId)
protected void	executeMembershipUpdate(PlatformUserEntity platformUserEntity, String groupId, boolean addGroup)
protected UserDefinitionService	getUserDefinitionService()
boolean	isIndexingEnabled()
void	scheduleMembershipAddedIndexing(PlatformUserEntity platformUserEntity, String groupId)
void	scheduleMembershipDeletedIndexing(PlatformUserEntity platformUserEntity, String groupId)
void	scheduleUserIndexDeletion(String userId)
void	scheduleUserIndexing(PlatformUserEntity platformUserEntity)
void	scheduleUserIndexing(PlatformUserEntity platformUserEntity, String index)
void	scheduleUserIndexing(PlatformUserEntity platformUserEntity, List<String> newGroupIds)	Schedules the indexing of a user.
void	scheduleUserIndexing(PlatformUserEntity platformUserEntity, List<String> newGroupIds, String index)

Methods inherited from class java.lang.Object

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

Field Details

MAPPING_TYPE_USER

public static final String MAPPING_TYPE_USER

See Also:

• Constant Field Values

indexingService

protected IndexingService indexingService

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

idmEngineConfiguration

protected CoreIdmEngineConfiguration idmEngineConfiguration

Constructor Details

IdmIndexingSchedulerImpl

public IdmIndexingSchedulerImpl(IndexingService indexingService,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 CoreIdmEngineConfiguration idmEngineConfiguration)

Method Details

scheduleUserIndexDeletion

public void scheduleUserIndexDeletion(String userId)

Specified by:

scheduleUserIndexDeletion in interface IdmIndexingScheduler

scheduleUserIndexing

public void scheduleUserIndexing(PlatformUserEntity platformUserEntity)

Specified by:

scheduleUserIndexing in interface IdmIndexingScheduler

scheduleUserIndexing

public void scheduleUserIndexing(PlatformUserEntity platformUserEntity,
 String index)

Specified by:

scheduleUserIndexing in interface IdmIndexingScheduler

scheduleUserIndexing

public void scheduleUserIndexing(PlatformUserEntity platformUserEntity,
 List<String> newGroupIds)

Description copied from interface: IdmIndexingScheduler

Schedules the indexing of a user.

Specified by:

scheduleUserIndexing in interface IdmIndexingScheduler

newGroupIds - Optional list of groups that are created in the same transaction as the user. When wanting simply a reindexing of a user, pass an empty optional.

scheduleUserIndexing

public void scheduleUserIndexing(PlatformUserEntity platformUserEntity,
 List<String> newGroupIds,
 String index)

Specified by:

scheduleUserIndexing in interface IdmIndexingScheduler

scheduleMembershipAddedIndexing

public void scheduleMembershipAddedIndexing(PlatformUserEntity platformUserEntity,
 String groupId)

Specified by:

scheduleMembershipAddedIndexing in interface IdmIndexingScheduler

scheduleMembershipDeletedIndexing

public void scheduleMembershipDeletedIndexing(PlatformUserEntity platformUserEntity,
 String groupId)

Specified by:

scheduleMembershipDeletedIndexing in interface IdmIndexingScheduler

executeMembershipUpdate

protected void executeMembershipUpdate(PlatformUserEntity platformUserEntity,
 String groupId,
 boolean addGroup)

getUserDefinitionService

protected UserDefinitionService getUserDefinitionService()

isIndexingEnabled

public boolean isIndexingEnabled()

addOrReplaceHistoricData

protected void addOrReplaceHistoricData(com.fasterxml.jackson.databind.node.ObjectNode dataNode,
 String tenantId)