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 and Description
protected BulkIndexRequestExecutor	bulkIndexRequestExecutor
static 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 and Description
IndexDataAsyncHistoryJobHandler(List<org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Summary

Modifier and Type	Method and Description
void	execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob, String configuration, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
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, 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 Detail

JOB_TYPE

public static final String JOB_TYPE

See Also:

Constant Field Values

bulkIndexRequestExecutor

protected BulkIndexRequestExecutor bulkIndexRequestExecutor

Constructor Detail

IndexDataAsyncHistoryJobHandler

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

Method Detail

execute

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

Specified by:

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

Overrides:

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

getType

public 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,
                                                  String type)

Overrides:

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