Package com.flowable.engage.engine.impl.cmd

Class ReindexMessagesCmd

java.lang.Object

com.flowable.engage.engine.impl.cmd.ReindexMessagesCmd

All Implemented Interfaces:

org.flowable.common.engine.impl.interceptor.Command<java.lang.Void>

public class ReindexMessagesCmd
extends java.lang.Object
implements org.flowable.common.engine.impl.interceptor.Command<java.lang.Void>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	conversationId
protected java.lang.String	indexName
static int	MESSAGE_PAGE_SIZE
protected int	pageSize
protected int	start

Constructor Summary

Constructors

Constructor	Description
ReindexMessagesCmd(java.lang.String conversationId)
ReindexMessagesCmd(java.lang.String indexName, int start, int pageSize)

Method Summary

Modifier and Type	Method	Description
protected java.util.Set<java.lang.String>	determineParticipantGroupIds(Message message, java.util.List<ConversationRegistryEntryEntity> registryEntities)
protected java.util.Set<java.lang.String>	determineParticipantUserIds(Message message, java.util.List<ConversationRegistryEntryEntity> registryEntities)
java.lang.Void	execute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected java.util.function.Predicate<ConversationRegistryEntryEntity>	isRegistryEntryApplicable(java.util.Date messageTime)
protected void	reindexMessagesForConversation(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, MessageEntityManager messageEntityManager, ConversationRegistryEntryEntityManager conversationRegistryEntryEntityManager)
protected void	reindexMessagesPage(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, MessageEntityManager messageEntityManager, ConversationRegistryEntryEntityManager conversationRegistryEntryEntityManager)

Methods inherited from class java.lang.Object

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

Field Details

MESSAGE_PAGE_SIZE

public static final int MESSAGE_PAGE_SIZE

See Also:

Constant Field Values

indexName

protected java.lang.String indexName

conversationId

protected java.lang.String conversationId

start

protected int start

pageSize

protected int pageSize

Constructor Details

ReindexMessagesCmd

public ReindexMessagesCmd(java.lang.String indexName, int start, int pageSize)

ReindexMessagesCmd

public ReindexMessagesCmd(java.lang.String conversationId)

Method Details

execute

public java.lang.Void execute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

Specified by:

execute in interface org.flowable.common.engine.impl.interceptor.Command<java.lang.Void>

reindexMessagesForConversation

protected void reindexMessagesForConversation(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, MessageEntityManager messageEntityManager, ConversationRegistryEntryEntityManager conversationRegistryEntryEntityManager)

reindexMessagesPage

protected void reindexMessagesPage(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, MessageEntityManager messageEntityManager, ConversationRegistryEntryEntityManager conversationRegistryEntryEntityManager)

determineParticipantUserIds

protected java.util.Set<java.lang.String> determineParticipantUserIds(Message message, java.util.List<ConversationRegistryEntryEntity> registryEntities)

determineParticipantGroupIds

protected java.util.Set<java.lang.String> determineParticipantGroupIds(Message message, java.util.List<ConversationRegistryEntryEntity> registryEntities)

isRegistryEntryApplicable

protected java.util.function.Predicate<ConversationRegistryEntryEntity> isRegistryEntryApplicable(java.util.Date messageTime)