Package com.flowable.indexing.job

Class IndexingAsyncHistoryJobProducer

java.lang.Object

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

com.flowable.indexing.job.IndexingAsyncHistoryJobProducer

All Implemented Interfaces:

AsyncHistoryListener

public class IndexingAsyncHistoryJobProducer
extends DefaultAsyncHistoryJobProducer

Extends the DefaultAsyncHistoryJobProducer to create a new HistoryJobEntity which is a copy of the one that is normally created. The reason for this is that otherwise the storing of the historical data will be done together with sending it to Elasticsearch. Both can fail independently or the relational db job handling might halfway decide the historical data is not yet applicable and roll back. To avoid this mixing, a copy of the original HistoryJobEntity is created with a specific HistoryJobHandler for Elasticsearch. This is a simple copy and no extra processing (json wise and such) is done.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	gzippingEnabled

Constructor Summary

Constructors

Constructor	Description
IndexingAsyncHistoryJobProducer(boolean gzippingEnabled)

Method Summary

Modifier and Type	Method	Description
protected String	getJobType(JobServiceConfiguration jobServiceConfiguration, boolean groupingEnabled)
protected void	processHistoryJobEntities(CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration, List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes, List<HistoryJobEntity> historyJobEntities)

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

addJsonToJob, compress, createJob, createJobsWithHistoricalData, historyDataGenerated, scheduleJobs

Methods inherited from class java.lang.Object

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

Field Detail

gzippingEnabled

protected boolean gzippingEnabled

Constructor Detail

IndexingAsyncHistoryJobProducer

public IndexingAsyncHistoryJobProducer(boolean gzippingEnabled)

Method Detail

processHistoryJobEntities

protected void processHistoryJobEntities(CommandContext commandContext,
                                         JobServiceConfiguration jobServiceConfiguration,
                                         List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes,
                                         List<HistoryJobEntity> historyJobEntities)

Overrides:

processHistoryJobEntities in class DefaultAsyncHistoryJobProducer

getJobType

protected String getJobType(JobServiceConfiguration jobServiceConfiguration,
                            boolean groupingEnabled)

Overrides:

getJobType in class DefaultAsyncHistoryJobProducer