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

Class AsyncIndexingHistorySession

java.lang.Object

com.flowable.indexing.job.history.async.AsyncIndexingHistorySession

All Implemented Interfaces:

org.flowable.common.engine.impl.interceptor.Session

public class AsyncIndexingHistorySession
extends Object
implements org.flowable.common.engine.impl.interceptor.Session

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncIndexingHistorySession.AsyncHistorySessionData	Wrapper for the async history job data, to avoid messing with maps and lists.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.flowable.common.engine.impl.interceptor.CommandContext	commandContext
protected org.flowable.common.engine.impl.interceptor.CommandContextCloseListener	commandContextCloseListener
protected List<String>	jobDataTypes
protected IndexingHistoryJobProducer	jobProducer
protected int	jobRetries
protected Map<org.flowable.job.service.JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData>	sessionData
protected List<String>	singleJobDataTypes
protected String	tenantId
static final String	TIMESTAMP
protected org.flowable.common.engine.impl.cfg.TransactionContext	transactionContext

Constructor Summary

Constructors

Constructor	Description
AsyncIndexingHistorySession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, IndexingHistoryJobProducer jobProducer, List<String> registeredJobDataTypes, List<String> registeredSingleJobDataTypes, int jobRetries)

Method Summary

Modifier and Type	Method	Description
void	addHistoricData(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, String type, com.fasterxml.jackson.databind.node.ObjectNode data)
void	addHistoricData(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, String type, com.fasterxml.jackson.databind.node.ObjectNode data, String tenantId)
void	addOrReplaceHistoricData(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, com.fasterxml.jackson.databind.node.ObjectNode dataNode, String dataIdFieldName, String type, String tenantId)
void	close()
void	flush()
List<String>	getJobDataTypes()
int	getJobRetries()
com.fasterxml.jackson.databind.node.ObjectNode	getMatchingData(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, String dataId, String dataIdFieldName, String type)
Map<org.flowable.job.service.JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData>	getSessionData()
List<String>	getSingleJobDataTypes()
String	getTenantId()
org.flowable.common.engine.impl.cfg.TransactionContext	getTransactionContext()
protected void	initCommandContextCloseListener()
void	setJobDataTypes(List<String> jobDataTypes)
void	setJobRetries(int jobRetries)
void	setSessionData(Map<org.flowable.job.service.JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> sessionData)
void	setTenantId(String tenantId)
void	setTransactionContext(org.flowable.common.engine.impl.cfg.TransactionContext transactionContext)

Methods inherited from class java.lang.Object

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

Field Details

TIMESTAMP

public static final String TIMESTAMP

See Also:

• Constant Field Values

jobRetries

protected int jobRetries

commandContext

protected org.flowable.common.engine.impl.interceptor.CommandContext commandContext

jobProducer

protected IndexingHistoryJobProducer jobProducer

commandContextCloseListener

protected org.flowable.common.engine.impl.interceptor.CommandContextCloseListener commandContextCloseListener

jobDataTypes

protected List<String> jobDataTypes

singleJobDataTypes

protected List<String> singleJobDataTypes

transactionContext

protected org.flowable.common.engine.impl.cfg.TransactionContext transactionContext

tenantId

protected String tenantId

sessionData

protected Map<org.flowable.job.service.JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> sessionData

Constructor Details

AsyncIndexingHistorySession

public AsyncIndexingHistorySession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 IndexingHistoryJobProducer jobProducer,
 List<String> registeredJobDataTypes,
 List<String> registeredSingleJobDataTypes,
 int jobRetries)

Method Details

initCommandContextCloseListener

protected void initCommandContextCloseListener()

addHistoricData

public void addHistoricData(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
 String type,
 com.fasterxml.jackson.databind.node.ObjectNode data)

addHistoricData

public void addHistoricData(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
 String type,
 com.fasterxml.jackson.databind.node.ObjectNode data,
 String tenantId)

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)

flush

public void flush()

Specified by:

flush in interface org.flowable.common.engine.impl.interceptor.Session

close

public void close()

Specified by:

close in interface org.flowable.common.engine.impl.interceptor.Session

getJobRetries

public int getJobRetries()

setJobRetries

public void setJobRetries(int jobRetries)

getTenantId

public String getTenantId()

setTenantId

public void setTenantId(String tenantId)

getSessionData

public Map<org.flowable.job.service.JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> getSessionData()

setSessionData

public void setSessionData(Map<org.flowable.job.service.JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> sessionData)

getJobDataTypes

public List<String> getJobDataTypes()

setJobDataTypes

public void setJobDataTypes(List<String> jobDataTypes)

getSingleJobDataTypes

public List<String> getSingleJobDataTypes()

getTransactionContext

public org.flowable.common.engine.impl.cfg.TransactionContext getTransactionContext()

setTransactionContext

public void setTransactionContext(org.flowable.common.engine.impl.cfg.TransactionContext transactionContext)