com.flowable.indexing.job.history.async

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 Object
implements org.flowable.common.engine.impl.interceptor.SessionFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected ElasticsearchCompatibility	elasticsearchCompatibility
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected org.elasticsearch.client.RestHighLevelClient	restHighLevelClient

Constructor Summary

Constructors

Constructor and Description
BulkIndexingSessionFactory(com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.elasticsearch.client.RestHighLevelClient restHighLevelClient, ElasticsearchCompatibility elasticsearchCompatibility, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Summary

Modifier and Type	Method and Description
Class<?>	getSessionType()
org.flowable.common.engine.impl.interceptor.Session	openSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

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

elasticsearchCompatibility

protected ElasticsearchCompatibility elasticsearchCompatibility

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

Constructor Detail

BulkIndexingSessionFactory

public BulkIndexingSessionFactory(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                  org.elasticsearch.client.RestHighLevelClient restHighLevelClient,
                                  ElasticsearchCompatibility elasticsearchCompatibility,
                                  List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Detail

getSessionType

public Class<?> getSessionType()

Specified by:

getSessionType in interface org.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 interface org.flowable.common.engine.impl.interceptor.SessionFactory