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

Class AsyncIndexingHistorySession

java.lang.Object

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

All Implemented Interfaces:

Session

public class AsyncIndexingHistorySession
extends Object
implements 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 CommandContext	commandContext
protected CommandContextCloseListener	commandContextCloseListener
protected List<String>	jobDataTypes
protected IndexingHistoryJobProducer	jobProducer
protected int	jobRetries
protected Map<JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData>	sessionData
protected String	tenantId
static final String	TIMESTAMP
protected TransactionContext	transactionContext

Constructor Summary

Constructors

Constructor	Description
AsyncIndexingHistorySession(CommandContext commandContext, IndexingHistoryJobProducer jobProducer, List<String> registeredJobDataTypes, int jobRetries)

Method Summary

Modifier and Type	Method	Description
void	addHistoricData(JobServiceConfiguration jobServiceConfiguration, String type, com.fasterxml.jackson.databind.node.ObjectNode data)
void	addHistoricData(JobServiceConfiguration jobServiceConfiguration, String type, com.fasterxml.jackson.databind.node.ObjectNode data, String tenantId)
void	addOrReplaceHistoricData(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(JobServiceConfiguration jobServiceConfiguration, String dataId, String dataIdFieldName, String type)
Map<JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData>	getSessionData()
String	getTenantId()
TransactionContext	getTransactionContext()
protected void	initCommandContextCloseListener()
void	setJobDataTypes(List<String> jobDataTypes)
void	setJobRetries(int jobRetries)
void	setSessionData(Map<JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> sessionData)
void	setTenantId(String tenantId)
void	setTransactionContext(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 CommandContext commandContext

jobProducer

protected IndexingHistoryJobProducer jobProducer

commandContextCloseListener

protected CommandContextCloseListener commandContextCloseListener

jobDataTypes

protected List<String> jobDataTypes

transactionContext

protected TransactionContext transactionContext

tenantId

protected String tenantId

sessionData

protected Map<JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> sessionData

Constructor Details

AsyncIndexingHistorySession

public AsyncIndexingHistorySession(CommandContext commandContext,
 IndexingHistoryJobProducer jobProducer,
 List<String> registeredJobDataTypes,
 int jobRetries)

Method Details

initCommandContextCloseListener

protected void initCommandContextCloseListener()

addHistoricData

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

addHistoricData

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

addOrReplaceHistoricData

public void addOrReplaceHistoricData(JobServiceConfiguration jobServiceConfiguration,
 com.fasterxml.jackson.databind.node.ObjectNode dataNode,
 String dataIdFieldName,
 String type,
 String tenantId)

getMatchingData

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

flush

public void flush()

Specified by:

flush in interface Session

close

public void close()

Specified by:

close in interface Session

getJobRetries

public int getJobRetries()

setJobRetries

public void setJobRetries(int jobRetries)

getTenantId

public String getTenantId()

setTenantId

public void setTenantId(String tenantId)

getSessionData

public Map<JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> getSessionData()

setSessionData

public void setSessionData(Map<JobServiceConfiguration,AsyncIndexingHistorySession.AsyncHistorySessionData> sessionData)

getJobDataTypes

public List<String> getJobDataTypes()

setJobDataTypes

public void setJobDataTypes(List<String> jobDataTypes)

getTransactionContext

public TransactionContext getTransactionContext()

setTransactionContext

public void setTransactionContext(TransactionContext transactionContext)