Package com.flowable.indexing.job.history.async

Class AsyncIndexingHistorySession

  • All Implemented Interfaces:
    org.flowable.common.engine.impl.interceptor.Session
    public class AsyncIndexingHistorySession
extends org.flowable.job.service.impl.history.async.AsyncHistorySession
    Author:
    Filip Hrisafov

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.flowable.job.service.impl.history.async.AsyncHistorySession

        org.flowable.job.service.impl.history.async.AsyncHistorySession.AsyncHistorySessionData

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected int jobRetries  

      • Fields inherited from class org.flowable.job.service.impl.history.async.AsyncHistorySession

        asyncHistoryListener, commandContext, commandContextCloseListener, jobDataTypes, sessionData, tenantId, TIMESTAMP, transactionContext

    • Constructor Summary

      Constructors 
      Constructor Description
      AsyncIndexingHistorySession​(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener, java.util.List<java.lang.String> registeredJobDataTypes)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addOrReplaceHistoricData​(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, com.fasterxml.jackson.databind.node.ObjectNode dataNode, java.lang.String dataIdFieldName, java.lang.String type, java.lang.String tenantId)  
      int getJobRetries()  
      com.fasterxml.jackson.databind.node.ObjectNode getMatchingData​(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, java.lang.String dataId, java.lang.String dataIdFieldName, java.lang.String type)  
      protected void initCommandContextCloseListener()  
      void setJobRetries​(int jobRetries)  

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

        addHistoricData, addHistoricData, close, flush, getAsyncHistoryListener, getJobDataTypes, getSessionData, getTenantId, getTransactionContext, setJobDataTypes, setSessionData, setTenantId, setTransactionContext

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • jobRetries

        protected int jobRetries

    • Constructor Detail

      • AsyncIndexingHistorySession

        public AsyncIndexingHistorySession​(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                                   org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener,
                                   java.util.List<java.lang.String> registeredJobDataTypes)

    • Method Detail

      • initCommandContextCloseListener

        protected void initCommandContextCloseListener()
        Overrides:
        initCommandContextCloseListener in class org.flowable.job.service.impl.history.async.AsyncHistorySession

      • addOrReplaceHistoricData

        public void addOrReplaceHistoricData​(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
                                     com.fasterxml.jackson.databind.node.ObjectNode dataNode,
                                     java.lang.String dataIdFieldName,
                                     java.lang.String type,
                                     java.lang.String tenantId)

      • getMatchingData

        public com.fasterxml.jackson.databind.node.ObjectNode getMatchingData​(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
                                                                      java.lang.String dataId,
                                                                      java.lang.String dataIdFieldName,
                                                                      java.lang.String type)

      • getJobRetries

        public int getJobRetries()

      • setJobRetries

        public void setJobRetries​(int jobRetries)