Package com.flowable.indexing

Class ProcessEngineIndexingConfigurator

java.lang.Object

org.flowable.engine.cfg.AbstractProcessEngineConfigurator

com.flowable.indexing.ProcessEngineIndexingConfigurator

All Implemented Interfaces:

org.flowable.common.engine.impl.EngineConfigurator

public class ProcessEngineIndexingConfigurator
extends org.flowable.engine.cfg.AbstractProcessEngineConfigurator

Field Summary

Fields

Modifier and Type	Field	Description
protected List<org.flowable.job.service.HistoryJobHandler>	asyncHistoryJobHandlers
protected org.flowable.common.engine.impl.interceptor.SessionFactory	asyncIndexingHistorySessionFactory
protected org.flowable.common.engine.impl.interceptor.SessionFactory	bulkIndexingSessionFactory
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected ElasticsearchClient	elasticsearchClient
protected IndexingHistoryJobProducer	jobProducer
protected int	numberOfRetries
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected ReindexManager	reindexManager

Fields inherited from class org.flowable.engine.cfg.AbstractProcessEngineConfigurator

DEFAULT_CONFIGURATOR_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ProcessEngineIndexingConfigurator(com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexingHistoryJobProducer jobProducer, List<org.flowable.job.service.HistoryJobHandler> asyncHistoryJobHandlers, ElasticsearchClient elasticsearchClient, ReindexManager reindexManager, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors, int numberOfRetries)

Method Summary

Modifier and Type	Method	Description
void	beforeInit(org.flowable.common.engine.impl.AbstractEngineConfiguration engineConfiguration)
void	configure(org.flowable.common.engine.impl.AbstractEngineConfiguration engineConfiguration)
org.flowable.common.engine.impl.interceptor.SessionFactory	getAsyncIndexingHistorySessionFactory()
protected void	initAsyncIndexingSessionFactory()
protected void	initBulkIndexingSessionFactory()
void	setAsyncIndexingHistorySessionFactory(org.flowable.common.engine.impl.interceptor.SessionFactory asyncIndexingHistorySessionFactory)

Methods inherited from class org.flowable.engine.cfg.AbstractProcessEngineConfigurator

getPriority

Methods inherited from class java.lang.Object

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

Field Details

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

jobProducer

protected IndexingHistoryJobProducer jobProducer

asyncHistoryJobHandlers

protected List<org.flowable.job.service.HistoryJobHandler> asyncHistoryJobHandlers

reindexManager

protected ReindexManager reindexManager

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

asyncIndexingHistorySessionFactory

protected org.flowable.common.engine.impl.interceptor.SessionFactory asyncIndexingHistorySessionFactory

bulkIndexingSessionFactory

protected org.flowable.common.engine.impl.interceptor.SessionFactory bulkIndexingSessionFactory

numberOfRetries

protected int numberOfRetries

Constructor Details

ProcessEngineIndexingConfigurator

public ProcessEngineIndexingConfigurator(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 IndexingHistoryJobProducer jobProducer,
 List<org.flowable.job.service.HistoryJobHandler> asyncHistoryJobHandlers,
 ElasticsearchClient elasticsearchClient,
 ReindexManager reindexManager,
 List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors,
 int numberOfRetries)

Method Details

beforeInit

public void beforeInit(org.flowable.common.engine.impl.AbstractEngineConfiguration engineConfiguration)

Specified by:

beforeInit in interface org.flowable.common.engine.impl.EngineConfigurator

Overrides:

beforeInit in class org.flowable.engine.cfg.AbstractProcessEngineConfigurator

configure

public void configure(org.flowable.common.engine.impl.AbstractEngineConfiguration engineConfiguration)

Specified by:

configure in interface org.flowable.common.engine.impl.EngineConfigurator

Overrides:

configure in class org.flowable.engine.cfg.AbstractProcessEngineConfigurator

initAsyncIndexingSessionFactory

protected void initAsyncIndexingSessionFactory()

initBulkIndexingSessionFactory

protected void initBulkIndexingSessionFactory()

getAsyncIndexingHistorySessionFactory

public org.flowable.common.engine.impl.interceptor.SessionFactory getAsyncIndexingHistorySessionFactory()

setAsyncIndexingHistorySessionFactory

public void setAsyncIndexingHistorySessionFactory(org.flowable.common.engine.impl.interceptor.SessionFactory asyncIndexingHistorySessionFactory)