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<Void>

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

Field Summary

Fields

Modifier and Type	Field and Description
protected String	indexName
protected int	pageSize
protected int	start

Constructor Summary

Constructors

Constructor and Description
ReindexMessagesCmd(String indexName, int start, int pageSize)

Method Summary

Modifier and Type	Method and Description
protected Set<String>	determineParticipantGroupIds(Message message, List<ConversationRegistryEntryEntity> registryEntities)
protected Set<String>	determineParticipantUserIds(Message message, List<ConversationRegistryEntryEntity> registryEntities)
Void	execute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected Predicate<ConversationRegistryEntryEntity>	isRegistryEntryApplicable(Date messageTime)

Methods inherited from class java.lang.Object

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

Field Detail

indexName

protected String indexName

start

protected int start

pageSize

protected int pageSize

Constructor Detail

ReindexMessagesCmd

public ReindexMessagesCmd(String indexName,
                          int start,
                          int pageSize)

Method Detail

execute

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

Specified by:

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

determineParticipantUserIds

protected Set<String> determineParticipantUserIds(Message message,
                                                  List<ConversationRegistryEntryEntity> registryEntities)

determineParticipantGroupIds

protected Set<String> determineParticipantGroupIds(Message message,
                                                   List<ConversationRegistryEntryEntity> registryEntities)

isRegistryEntryApplicable

protected Predicate<ConversationRegistryEntryEntity> isRegistryEntryApplicable(Date messageTime)