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 and Description
protected List<org.flowable.job.service.HistoryJobHandler>	asyncHistoryJobHandlers
protected org.flowable.job.service.impl.history.async.AsyncHistoryListener	asyncHistoryListener
protected org.flowable.common.engine.impl.interceptor.SessionFactory	asyncIndexingHistorySessionFactory
protected org.flowable.common.engine.impl.interceptor.SessionFactory	bulkIndexingSessionFactory
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected ElasticsearchCompatibility	elasticsearchCompatibility
protected boolean	jsonGroupingEnabled
protected int	jsonGroupingThreshold
protected boolean	jsonGzipEnabled
protected int	numberOfRetries
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected ReindexManager	reindexManager
protected org.elasticsearch.client.RestHighLevelClient	restHighLevelClient

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

DEFAULT_CONFIGURATOR_PRIORITY

Constructor Summary

Constructors

Constructor and Description

ProcessEngineIndexingConfigurator(com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.elasticsearch.client.RestHighLevelClient restHighLevelClient, org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener, List<org.flowable.job.service.HistoryJobHandler> asyncHistoryJobHandlers, ElasticsearchCompatibility elasticsearchCompatibility, ReindexManager reindexManager, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors, int numberOfRetries, boolean jsonGroupingEnabled, int jsonGroupingThreshold, boolean jsonGzipEnabled)

Method Summary

Modifier and Type	Method and 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 Detail

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

restHighLevelClient

protected org.elasticsearch.client.RestHighLevelClient restHighLevelClient

asyncHistoryListener

protected org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener

asyncHistoryJobHandlers

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

reindexManager

protected ReindexManager reindexManager

elasticsearchCompatibility

protected ElasticsearchCompatibility elasticsearchCompatibility

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

jsonGroupingEnabled

protected boolean jsonGroupingEnabled

jsonGroupingThreshold

protected int jsonGroupingThreshold

jsonGzipEnabled

protected boolean jsonGzipEnabled

Constructor Detail

ProcessEngineIndexingConfigurator

public ProcessEngineIndexingConfigurator(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                         org.elasticsearch.client.RestHighLevelClient restHighLevelClient,
                                         org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener,
                                         List<org.flowable.job.service.HistoryJobHandler> asyncHistoryJobHandlers,
                                         ElasticsearchCompatibility elasticsearchCompatibility,
                                         ReindexManager reindexManager,
                                         List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors,
                                         int numberOfRetries,
                                         boolean jsonGroupingEnabled,
                                         int jsonGroupingThreshold,
                                         boolean jsonGzipEnabled)

Method Detail

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)