Package com.flowable.indexing.job

Class AbstractAsyncHistoryJobHandler

java.lang.Object

com.flowable.indexing.job.AbstractAsyncHistoryJobHandler

All Implemented Interfaces:

HistoryJobHandler

Direct Known Subclasses:

IndexDataAsyncHistoryJobHandler

public abstract class AbstractAsyncHistoryJobHandler
extends Object
implements HistoryJobHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	isAsyncHistoryJsonGroupingEnabled
protected final String	jobType
protected final org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
AbstractAsyncHistoryJobHandler(String jobType)

Method Summary

Modifier and Type	Method	Description
void	execute(HistoryJobEntity job, String configuration, CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration)
protected abstract List<HistoryJobEntity>	generateHistoryJobs(JobServiceConfiguration jobServiceConfiguration, List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes)
protected byte[]	getJobBytes(HistoryJobEntity job)
String	getType()
boolean	isAsyncHistoryJsonGroupingEnabled()
protected abstract void	processHistoryJson(CommandContext commandContext, HistoryJobEntity job, com.fasterxml.jackson.databind.JsonNode historyNode)
void	setAsyncHistoryJsonGroupingEnabled(boolean isAsyncHistoryJsonGroupingEnabled)

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.slf4j.Logger logger

jobType

protected final String jobType

isAsyncHistoryJsonGroupingEnabled

protected boolean isAsyncHistoryJsonGroupingEnabled

Constructor Details

AbstractAsyncHistoryJobHandler

public AbstractAsyncHistoryJobHandler(String jobType)

Method Details

getType

public String getType()

Specified by:

getType in interface HistoryJobHandler

execute

public void execute(HistoryJobEntity job,
 String configuration,
 CommandContext commandContext,
 JobServiceConfiguration jobServiceConfiguration)

Specified by:

execute in interface HistoryJobHandler

generateHistoryJobs

protected abstract List<HistoryJobEntity> generateHistoryJobs(JobServiceConfiguration jobServiceConfiguration,
 List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes)

getJobBytes

protected byte[] getJobBytes(HistoryJobEntity job)

processHistoryJson

protected abstract void processHistoryJson(CommandContext commandContext,
 HistoryJobEntity job,
 com.fasterxml.jackson.databind.JsonNode historyNode)

isAsyncHistoryJsonGroupingEnabled

public boolean isAsyncHistoryJsonGroupingEnabled()

setAsyncHistoryJsonGroupingEnabled

public void setAsyncHistoryJsonGroupingEnabled(boolean isAsyncHistoryJsonGroupingEnabled)