Package com.flowable.indexing.job

Class IndexDataAsyncHistoryJobHandler

java.lang.Object

org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

com.flowable.indexing.job.IndexDataAsyncHistoryJobHandler

All Implemented Interfaces:

org.flowable.job.service.HistoryJobHandler

public class IndexDataAsyncHistoryJobHandler
extends org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected BulkIndexRequestExecutor	bulkIndexRequestExecutor
static java.lang.String	JOB_TYPE

Fields inherited from class org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

defaultHistoryJsonTransformer, historyJsonTransformers

Fields inherited from class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

isAsyncHistoryJsonGroupingEnabled, jobType, logger

Constructor Summary

Constructors

Constructor	Description
IndexDataAsyncHistoryJobHandler(java.util.List<org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Summary

Modifier and Type	Method	Description
void	execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob, java.lang.String configuration, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration)
java.lang.String	getType()
protected void	handleNoMatchingHistoryTransformer(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, java.lang.String type)

Methods inherited from class org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

addHistoryJsonTransformer, executeHistoryTransformers, getDefaultHistoryJsonTransformer, getHistoryJsonTransformers, processHistoryJson, setDefaultHistoryJsonTransformer, setHistoryJsonTransformers

Methods inherited from class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

getJobBytes, isAsyncHistoryJsonGroupingEnabled, setAsyncHistoryJsonGroupingEnabled

Methods inherited from class java.lang.Object

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

Field Details

JOB_TYPE

public static final java.lang.String JOB_TYPE

See Also:

Constant Field Values

bulkIndexRequestExecutor

protected BulkIndexRequestExecutor bulkIndexRequestExecutor

Constructor Details

IndexDataAsyncHistoryJobHandler

public IndexDataAsyncHistoryJobHandler(java.util.List<org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Details

execute

public void execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob, java.lang.String configuration, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration)

Specified by:

execute in interface org.flowable.job.service.HistoryJobHandler

Overrides:

execute in class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

getType

public java.lang.String getType()

Specified by:

getType in interface org.flowable.job.service.HistoryJobHandler

Overrides:

getType in class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

handleNoMatchingHistoryTransformer

protected void handleNoMatchingHistoryTransformer(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, java.lang.String type)

Overrides:

handleNoMatchingHistoryTransformer in class org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler