Package com.flowable.indexing.job.history.async

Class BulkIndexingSessionFactory

java.lang.Object

com.flowable.indexing.job.history.async.BulkIndexingSessionFactory

All Implemented Interfaces:

SessionFactory

public class BulkIndexingSessionFactory
extends Object
implements 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()
Session	openSession(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

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

Constructor Detail

BulkIndexingSessionFactory

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

Method Detail

getSessionType

public Class<?> getSessionType()

Specified by:

getSessionType in interface SessionFactory

openSession

public Session openSession(CommandContext commandContext)

Specified by:

openSession in interface SessionFactory