Package com.flowable.indexing.job

Class 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  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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 Detail

      • gzippingEnabled

        protected boolean gzippingEnabled

    • Constructor Detail

      • IndexingAsyncHistoryJobProducer

        public IndexingAsyncHistoryJobProducer​(boolean gzippingEnabled)

    • Method Detail

      • 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