Package 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 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)

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 java.util.List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

Constructor Detail

BulkIndexingSessionFactory

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

Method Detail

getSessionType

public java.lang.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