Class BulkIndexingSessionFactory
java.lang.Object
com.flowable.indexing.job.history.async.BulkIndexingSessionFactory
- All Implemented Interfaces:
org.flowable.common.engine.impl.interceptor.SessionFactory
public class BulkIndexingSessionFactory
extends java.lang.Object
implements org.flowable.common.engine.impl.interceptor.SessionFactory
-
Field Summary
Fields Modifier and Type Field Description protected java.util.List<BulkIndexRequestInterceptor>
bulkIndexRequestInterceptors
protected ElasticsearchCompatibility
elasticsearchCompatibility
protected com.fasterxml.jackson.databind.ObjectMapper
objectMapper
protected org.elasticsearch.client.RestHighLevelClient
restHighLevelClient
-
Constructor Summary
Constructors Constructor Description BulkIndexingSessionFactory(com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.elasticsearch.client.RestHighLevelClient restHighLevelClient, ElasticsearchCompatibility elasticsearchCompatibility, java.util.List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)
-
Method Summary
Modifier and Type Method Description java.lang.Class<?>
getSessionType()
org.flowable.common.engine.impl.interceptor.Session
openSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
-
Field Details
-
objectMapper
protected com.fasterxml.jackson.databind.ObjectMapper objectMapper -
restHighLevelClient
protected org.elasticsearch.client.RestHighLevelClient restHighLevelClient -
elasticsearchCompatibility
-
bulkIndexRequestInterceptors
-
-
Constructor Details
-
BulkIndexingSessionFactory
public BulkIndexingSessionFactory(com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.elasticsearch.client.RestHighLevelClient restHighLevelClient, ElasticsearchCompatibility elasticsearchCompatibility, java.util.List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)
-
-
Method Details
-
getSessionType
public java.lang.Class<?> getSessionType()- Specified by:
getSessionType
in interfaceorg.flowable.common.engine.impl.interceptor.SessionFactory
-
openSession
public org.flowable.common.engine.impl.interceptor.Session openSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)- Specified by:
openSession
in interfaceorg.flowable.common.engine.impl.interceptor.SessionFactory
-