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

Field Summary

Fields

Modifier and Type	Field	Description
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected ElasticsearchClient	elasticsearchClient
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor	Description
BulkIndexingSessionFactory(com.fasterxml.jackson.databind.ObjectMapper objectMapper, ElasticsearchClient elasticsearchClient, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Summary

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

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

Constructor Details

BulkIndexingSessionFactory

public BulkIndexingSessionFactory(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 ElasticsearchClient elasticsearchClient,
 List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Details

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