public class IndexingAsyncHistoryJobProducer
extends org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer
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.Modifier and Type | Field and Description |
---|---|
protected boolean |
gzippingEnabled |
Constructor and Description |
---|
IndexingAsyncHistoryJobProducer(boolean gzippingEnabled) |
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) |
public IndexingAsyncHistoryJobProducer(boolean gzippingEnabled)
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)
createAndInsertJobEntity
in class org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer
protected String getJobType(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, boolean groupingEnabled)
getJobType
in class org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer
Copyright © 2019. All rights reserved.