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:
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 Description
    protected boolean gzippingEnabled  

  • Constructor Summary

    Constructors 
    Constructor Description
    IndexingAsyncHistoryJobProducer​(boolean gzippingEnabled)  

  • Method Summary

    Modifier and Type Method Description
    protected java.lang.String getJobType​(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, boolean groupingEnabled)  
    protected void processHistoryJobEntities​(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, java.util.List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes, java.util.List<org.flowable.job.service.impl.persistence.entity.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 Details

  • Constructor Details

  • Method Details

    • processHistoryJobEntities

      protected void processHistoryJobEntities​(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, java.util.List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes, java.util.List<org.flowable.job.service.impl.persistence.entity.HistoryJobEntity> historyJobEntities)
      Overrides:
      processHistoryJobEntities in class org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer

    • getJobType

      protected java.lang.String getJobType​(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, boolean groupingEnabled)
      Overrides:
      getJobType in class org.flowable.job.service.impl.history.async.DefaultAsyncHistoryJobProducer