Modifier and Type | Field and Description |
---|---|
protected String |
indexName |
protected int |
pageSize |
protected int |
start |
Constructor and Description |
---|
ReindexMessagesCmd(String indexName,
int start,
int pageSize) |
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) |
protected String indexName
protected int start
protected int pageSize
public ReindexMessagesCmd(String indexName, int start, int pageSize)
public Void execute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
execute
in interface org.flowable.common.engine.impl.interceptor.Command<Void>
protected Set<String> determineParticipantUserIds(Message message, List<ConversationRegistryEntryEntity> registryEntities)
protected Set<String> determineParticipantGroupIds(Message message, List<ConversationRegistryEntryEntity> registryEntities)
protected Predicate<ConversationRegistryEntryEntity> isRegistryEntryApplicable(Date messageTime)
Copyright © 2019. All rights reserved.