com.flowable.engage.engine.impl.indexing

Class EngageIndexingSchedulerImpl

java.lang.Object

com.flowable.engage.engine.impl.indexing.EngageIndexingSchedulerImpl

All Implemented Interfaces:

EngageIndexingScheduler

public class EngageIndexingSchedulerImpl
extends Object
implements EngageIndexingScheduler

Field Summary

Fields

Modifier and Type	Field and Description
protected EngageEngineConfiguration	engageEngineConfiguration
protected com.flowable.indexing.api.IndexingService	indexingService
static String	MAPPING_TYPE_CONVERSATION
static String	MAPPING_TYPE_MESSAGE
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
static String	TYPE_INDEX_CONVERSATION
static String	TYPE_INDEX_MESSAGE

Constructor Summary

Constructors

Constructor and Description
EngageIndexingSchedulerImpl(com.flowable.indexing.api.IndexingService indexingService, com.fasterxml.jackson.databind.ObjectMapper objectMapper, EngageEngineConfiguration engageEngineConfiguration)

Method Summary

Modifier and Type	Method and Description
protected void	enhanceWithCachedUsers(Map<String,com.flowable.core.idm.api.PlatformUser> participants, List<String> requestedUserIds)
protected Map<String,com.flowable.core.idm.api.PlatformUser>	extractParticipants(List<org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity> identityLinks, String tenantId, boolean checkCache)
protected com.flowable.core.idm.api.PlatformIdentityService	getIdmIdentityService()
protected static boolean	isAcceptableType(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)
protected boolean	isIndexingDisabled()
boolean	isIndexingEnabled()
void	scheduleConversationDeletion(String conversationId)
void	scheduleConversationIndexing(ConversationEntity conversationEntity)
void	scheduleConversationIndexing(ConversationEntity conversationEntity, String index)
void	scheduleConversationLastMessageUpdate(ConversationEntity conversationEntity)
void	scheduleConversationsParticipantAvatarUpdate(com.flowable.core.idm.api.PlatformUser platformUser, com.flowable.core.idm.api.PlatformUser oldUser)
void	scheduleConversationsParticipantUpdate(com.flowable.core.idm.api.PlatformUser platformUser, com.flowable.core.idm.api.PlatformUser oldUser)
void	scheduleMessageDeletion(String messageId)
void	scheduleMessageIndexing(ConversationEntity conversationEntity, MessageEntity messageEntity)
void	scheduleMessageIndexing(ConversationEntity conversationEntity, MessageEntity messageEntity, String index)
void	scheduleMessageIndexing(MessageEntity messageEntity, Collection<String> participantUserIds, Collection<String> participantGroupIds, String index)

Methods inherited from class java.lang.Object

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

Field Detail

TYPE_INDEX_MESSAGE

public static final String TYPE_INDEX_MESSAGE

See Also:

Constant Field Values

TYPE_INDEX_CONVERSATION

public static final String TYPE_INDEX_CONVERSATION

See Also:

Constant Field Values

MAPPING_TYPE_MESSAGE

public static final String MAPPING_TYPE_MESSAGE

See Also:

Constant Field Values

MAPPING_TYPE_CONVERSATION

public static final String MAPPING_TYPE_CONVERSATION

See Also:

Constant Field Values

indexingService

protected com.flowable.indexing.api.IndexingService indexingService

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

engageEngineConfiguration

protected EngageEngineConfiguration engageEngineConfiguration

Constructor Detail

EngageIndexingSchedulerImpl

public EngageIndexingSchedulerImpl(com.flowable.indexing.api.IndexingService indexingService,
                                   com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                   EngageEngineConfiguration engageEngineConfiguration)

Method Detail

scheduleMessageIndexing

public void scheduleMessageIndexing(ConversationEntity conversationEntity,
                                    MessageEntity messageEntity)

Specified by:

scheduleMessageIndexing in interface EngageIndexingScheduler

scheduleMessageIndexing

public void scheduleMessageIndexing(ConversationEntity conversationEntity,
                                    MessageEntity messageEntity,
                                    String index)

Specified by:

scheduleMessageIndexing in interface EngageIndexingScheduler

scheduleMessageIndexing

public void scheduleMessageIndexing(MessageEntity messageEntity,
                                    Collection<String> participantUserIds,
                                    Collection<String> participantGroupIds,
                                    String index)

Specified by:

scheduleMessageIndexing in interface EngageIndexingScheduler

scheduleConversationIndexing

public void scheduleConversationIndexing(ConversationEntity conversationEntity)

Specified by:

scheduleConversationIndexing in interface EngageIndexingScheduler

scheduleConversationIndexing

public void scheduleConversationIndexing(ConversationEntity conversationEntity,
                                         String index)

Specified by:

scheduleConversationIndexing in interface EngageIndexingScheduler

scheduleConversationLastMessageUpdate

public void scheduleConversationLastMessageUpdate(ConversationEntity conversationEntity)

Specified by:

scheduleConversationLastMessageUpdate in interface EngageIndexingScheduler

scheduleConversationsParticipantUpdate

public void scheduleConversationsParticipantUpdate(com.flowable.core.idm.api.PlatformUser platformUser,
                                                   com.flowable.core.idm.api.PlatformUser oldUser)

Specified by:

scheduleConversationsParticipantUpdate in interface EngageIndexingScheduler

scheduleConversationsParticipantAvatarUpdate

public void scheduleConversationsParticipantAvatarUpdate(com.flowable.core.idm.api.PlatformUser platformUser,
                                                         com.flowable.core.idm.api.PlatformUser oldUser)

Specified by:

scheduleConversationsParticipantAvatarUpdate in interface EngageIndexingScheduler

scheduleConversationDeletion

public void scheduleConversationDeletion(String conversationId)

Specified by:

scheduleConversationDeletion in interface EngageIndexingScheduler

scheduleMessageDeletion

public void scheduleMessageDeletion(String messageId)

Specified by:

scheduleMessageDeletion in interface EngageIndexingScheduler

getIdmIdentityService

protected com.flowable.core.idm.api.PlatformIdentityService getIdmIdentityService()

isIndexingDisabled

protected boolean isIndexingDisabled()

isIndexingEnabled

public boolean isIndexingEnabled()

extractParticipants

protected Map<String,com.flowable.core.idm.api.PlatformUser> extractParticipants(List<org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity> identityLinks,
                                                                                 String tenantId,
                                                                                 boolean checkCache)

enhanceWithCachedUsers

protected void enhanceWithCachedUsers(Map<String,com.flowable.core.idm.api.PlatformUser> participants,
                                      List<String> requestedUserIds)

isAcceptableType

protected static boolean isAcceptableType(org.flowable.identitylink.service.impl.persistence.entity.IdentityLinkEntity identityLink)