public class ProcessEngineIndexingConfigurator
extends org.flowable.engine.cfg.AbstractProcessEngineConfigurator
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 |
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) |
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) |
protected com.fasterxml.jackson.databind.ObjectMapper objectMapper
protected org.elasticsearch.client.RestHighLevelClient restHighLevelClient
protected org.flowable.job.service.impl.history.async.AsyncHistoryListener asyncHistoryListener
protected List<org.flowable.job.service.HistoryJobHandler> asyncHistoryJobHandlers
protected ReindexManager reindexManager
protected ElasticsearchCompatibility elasticsearchCompatibility
protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors
protected org.flowable.common.engine.impl.interceptor.SessionFactory asyncIndexingHistorySessionFactory
protected org.flowable.common.engine.impl.interceptor.SessionFactory bulkIndexingSessionFactory
protected int numberOfRetries
protected boolean jsonGroupingEnabled
protected int jsonGroupingThreshold
protected boolean jsonGzipEnabled
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)
public void beforeInit(org.flowable.common.engine.impl.AbstractEngineConfiguration engineConfiguration)
beforeInit
in interface org.flowable.common.engine.impl.EngineConfigurator
beforeInit
in class org.flowable.engine.cfg.AbstractProcessEngineConfigurator
public void configure(org.flowable.common.engine.impl.AbstractEngineConfiguration engineConfiguration)
configure
in interface org.flowable.common.engine.impl.EngineConfigurator
configure
in class org.flowable.engine.cfg.AbstractProcessEngineConfigurator
protected void initAsyncIndexingSessionFactory()
protected void initBulkIndexingSessionFactory()
public org.flowable.common.engine.impl.interceptor.SessionFactory getAsyncIndexingHistorySessionFactory()
public void setAsyncIndexingHistorySessionFactory(org.flowable.common.engine.impl.interceptor.SessionFactory asyncIndexingHistorySessionFactory)
Copyright © 2019. All rights reserved.