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:

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

public class IndexingAsyncHistoryJobProducer
extends org.flowable.job.service.impl.history.async.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 and Description
protected boolean	gzippingEnabled

Constructor Summary

Constructors

Constructor and Description
IndexingAsyncHistoryJobProducer(boolean gzippingEnabled)

Method Summary

Modifier and Type	Method and Description
protected org.flowable.job.service.impl.persistence.entity.HistoryJobEntity	createAndInsertJobEntity(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.history.async.AsyncHistorySession asyncHistorySession, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, String jobType)
protected String	getJobType(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, boolean groupingEnabled)

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

addJsonToJob, compress, createJobsWithHistoricalData, historyDataGenerated, processHistoryJobEntities

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

createAndInsertJobEntity

protected org.flowable.job.service.impl.persistence.entity.HistoryJobEntity createAndInsertJobEntity(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                                                                                                     org.flowable.job.service.impl.history.async.AsyncHistorySession asyncHistorySession,
                                                                                                     org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
                                                                                                     String jobType)

Overrides:

createAndInsertJobEntity in class org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer

getJobType

protected String getJobType(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
                            boolean groupingEnabled)

Overrides:

getJobType in class org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer