Package com.flowable.indexing

Class ProcessEngineIndexingConfigurator

java.lang.Object

org.flowable.engine.cfg.AbstractProcessEngineConfigurator

com.flowable.indexing.ProcessEngineIndexingConfigurator

All Implemented Interfaces:

EngineConfigurator

public class ProcessEngineIndexingConfigurator
extends AbstractProcessEngineConfigurator

Field Summary

Fields

Modifier and Type	Field	Description
protected List<HistoryJobHandler>	asyncHistoryJobHandlers
protected AsyncHistoryListener	asyncHistoryListener
protected SessionFactory	asyncIndexingHistorySessionFactory
protected SessionFactory	bulkIndexingSessionFactory
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected ElasticsearchClient	elasticsearchClient
protected boolean	jsonGroupingEnabled
protected int	jsonGroupingThreshold
protected boolean	jsonGzipEnabled
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, AsyncHistoryListener asyncHistoryListener, List<HistoryJobHandler> asyncHistoryJobHandlers, ElasticsearchClient elasticsearchClient, ReindexManager reindexManager, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors, int numberOfRetries, boolean jsonGroupingEnabled, int jsonGroupingThreshold, boolean jsonGzipEnabled)

Method Summary

Modifier and Type	Method	Description
void	beforeInit(AbstractEngineConfiguration engineConfiguration)
void	configure(AbstractEngineConfiguration engineConfiguration)
SessionFactory	getAsyncIndexingHistorySessionFactory()
protected void	initAsyncIndexingSessionFactory()
protected void	initBulkIndexingSessionFactory()
void	setAsyncIndexingHistorySessionFactory(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 Detail

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

asyncHistoryListener

protected AsyncHistoryListener asyncHistoryListener

asyncHistoryJobHandlers

protected List<HistoryJobHandler> asyncHistoryJobHandlers

reindexManager

protected ReindexManager reindexManager

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

asyncIndexingHistorySessionFactory

protected SessionFactory asyncIndexingHistorySessionFactory

bulkIndexingSessionFactory

protected SessionFactory bulkIndexingSessionFactory

numberOfRetries

protected int numberOfRetries

jsonGroupingEnabled

protected boolean jsonGroupingEnabled

jsonGroupingThreshold

protected int jsonGroupingThreshold

jsonGzipEnabled

protected boolean jsonGzipEnabled

Constructor Detail

ProcessEngineIndexingConfigurator

public ProcessEngineIndexingConfigurator(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                         AsyncHistoryListener asyncHistoryListener,
                                         List<HistoryJobHandler> asyncHistoryJobHandlers,
                                         ElasticsearchClient elasticsearchClient,
                                         ReindexManager reindexManager,
                                         List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors,
                                         int numberOfRetries,
                                         boolean jsonGroupingEnabled,
                                         int jsonGroupingThreshold,
                                         boolean jsonGzipEnabled)

Method Detail

beforeInit

public void beforeInit(AbstractEngineConfiguration engineConfiguration)

Specified by:

beforeInit in interface EngineConfigurator

Overrides:

beforeInit in class AbstractProcessEngineConfigurator

configure

public void configure(AbstractEngineConfiguration engineConfiguration)

Specified by:

configure in interface EngineConfigurator

Overrides:

configure in class AbstractProcessEngineConfigurator

initAsyncIndexingSessionFactory

protected void initAsyncIndexingSessionFactory()

initBulkIndexingSessionFactory

protected void initBulkIndexingSessionFactory()

getAsyncIndexingHistorySessionFactory

public SessionFactory getAsyncIndexingHistorySessionFactory()

setAsyncIndexingHistorySessionFactory

public void setAsyncIndexingHistorySessionFactory(SessionFactory asyncIndexingHistorySessionFactory)