Package org.openiam.esb.elasticsearch.reindex.impl

Class ElasticsearchReindexProcessorImpl

java.lang.Object

org.openiam.esb.elasticsearch.reindex.impl.ElasticsearchReindexProcessorImpl

All Implemented Interfaces:

ElasticsearchReindexProcessor, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

@Service("elasticsearchReindexProcessor")
public class ElasticsearchReindexProcessorImpl
extends Object
implements org.springframework.context.ApplicationContextAware, ElasticsearchReindexProcessor

Constructor Summary

Constructors

Constructor	Description
ElasticsearchReindexProcessorImpl(org.springframework.data.elasticsearch.core.ElasticsearchOperations elasticSearchTemplate, org.springframework.transaction.support.TransactionTemplate transactionTemplate, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor workerTaskExecutor, org.redisson.api.RedissonClient redissonClient)

Method Summary

Modifier and Type	Method	Description
List<Class<?>>	getIndexedClasses()
void	init()
int	reindex(Class<?> documentClazz)
int	reindex(Class<?> entityClass, Collection<String> ids)
void	reindexAll()
void	setApplicationContext(org.springframework.context.ApplicationContext ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ElasticsearchReindexProcessorImpl

public ElasticsearchReindexProcessorImpl(org.springframework.data.elasticsearch.core.ElasticsearchOperations elasticSearchTemplate,
                                         @Qualifier("transactionTemplate")
                                         org.springframework.transaction.support.TransactionTemplate transactionTemplate,
                                         @Qualifier("workerTaskExecutor")
                                         org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor workerTaskExecutor,
                                         org.redisson.api.RedissonClient redissonClient)

Method Detail

getIndexedClasses

public List<Class<?>> getIndexedClasses()

Specified by:

getIndexedClasses in interface ElasticsearchReindexProcessor

init

@PostConstruct
public void init()

reindexAll

public void reindexAll()

Specified by:

reindexAll in interface ElasticsearchReindexProcessor

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext ctx)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

reindex

@Transactional
public int reindex(Class<?> documentClazz)

Specified by:

reindex in interface ElasticsearchReindexProcessor

reindex

@Transactional(readOnly=true)
public int reindex(Class<?> entityClass,
                   Collection<String> ids)

Specified by:

reindex in interface ElasticsearchReindexProcessor