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 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(IndexingService indexingService, com.fasterxml.jackson.databind.ObjectMapper objectMapper, EngageEngineConfiguration engageEngineConfiguration)

Method Summary

Modifier and Type	Method and Description
protected void	enhanceWithCachedUsers(Map<String,PlatformUser> participants, List<String> requestedUserIds)
protected Map<String,PlatformUser>	extractParticipants(List<IdentityLinkEntity> identityLinks, String tenantId, boolean checkCache)
protected PlatformIdentityService	getIdmIdentityService()
protected static boolean	isAcceptableType(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(PlatformUser platformUser, PlatformUser oldUser)
void	scheduleConversationsParticipantUpdate(PlatformUser platformUser, 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)
void	scheduleMessagesParticipantAdded(ConversationEntity conversationEntity, Collection<String> participantUserIds, Date joiningTime)

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 IndexingService indexingService

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

engageEngineConfiguration

protected EngageEngineConfiguration engageEngineConfiguration

Constructor Detail

EngageIndexingSchedulerImpl

public EngageIndexingSchedulerImpl(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

scheduleMessagesParticipantAdded

public void scheduleMessagesParticipantAdded(ConversationEntity conversationEntity,
                                             Collection<String> participantUserIds,
                                             Date joiningTime)

Specified by:

scheduleMessagesParticipantAdded 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(PlatformUser platformUser,
                                                   PlatformUser oldUser)

Specified by:

scheduleConversationsParticipantUpdate in interface EngageIndexingScheduler

scheduleConversationsParticipantAvatarUpdate

public void scheduleConversationsParticipantAvatarUpdate(PlatformUser platformUser,
                                                         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 PlatformIdentityService getIdmIdentityService()

isIndexingDisabled

protected boolean isIndexingDisabled()

isIndexingEnabled

public boolean isIndexingEnabled()

extractParticipants

protected Map<String,PlatformUser> extractParticipants(List<IdentityLinkEntity> identityLinks,
                                                       String tenantId,
                                                       boolean checkCache)

enhanceWithCachedUsers

protected void enhanceWithCachedUsers(Map<String,PlatformUser> participants,
                                      List<String> requestedUserIds)

isAcceptableType

protected static boolean isAcceptableType(IdentityLinkEntity identityLink)