com.flowable.indexing.job.history.async

Class AsyncIndexingHistorySession

java.lang.Object

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

com.flowable.indexing.job.history.async.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 and 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 and Description
AsyncIndexingHistorySession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener, List<String> registeredJobDataTypes)

Method Summary

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

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

addHistoricData, addHistoricData, addHistoricData, addHistoricData, close, flush, getJobDataTypes, getSessionData, getTenantId, getTransactionContext, isAsyncHistoryExecutorEnabled, 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,
                                   List<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,
                                     String dataIdFieldName,
                                     String type,
                                     String tenantId)

getMatchingData

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

getJobRetries

public int getJobRetries()

setJobRetries

public void setJobRetries(int jobRetries)