Class DefaultIndexerWorker
java.lang.Object
de.hybris.platform.solrfacetsearch.indexer.workers.impl.DefaultIndexerWorker
- All Implemented Interfaces:
IndexerWorker,Runnable
Default implementation of
IndexerWorker.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprotected voiddoRun()protected Stringvoidinitialize(IndexerWorkerParameters workerParameters) Initializes the worker.protected voidbooleanIndicates if the worker is initialized and ready to run.protected voidlogWorkerError(Exception exception) protected voidprotected voidprotected voidprotected voidvoidrun()voidsetCommonI18NService(CommonI18NService commonI18NService) voidsetFacetSearchConfigService(FacetSearchConfigService facetSearchConfigService) voidsetIndexerBatchStrategyFactory(IndexerBatchStrategyFactory indexerBatchStrategyFactory) voidsetSessionService(SessionService sessionService) voidsetSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory) voidsetUserService(UserService userService)
-
Constructor Details
-
DefaultIndexerWorker
public DefaultIndexerWorker()
-
-
Method Details
-
getSessionService
-
setSessionService
-
getUserService
-
setUserService
-
getCommonI18NService
-
setCommonI18NService
-
getFacetSearchConfigService
-
setFacetSearchConfigService
-
getIndexerBatchStrategyFactory
-
setIndexerBatchStrategyFactory
-
getSolrSearchProviderFactory
-
setSolrSearchProviderFactory
-
initialize
Description copied from interface:IndexerWorkerInitializes the worker.- Specified by:
initializein interfaceIndexerWorker- Parameters:
workerParameters- the worker parameters
-
isInitialized
public boolean isInitialized()Description copied from interface:IndexerWorkerIndicates if the worker is initialized and ready to run.- Specified by:
isInitializedin interfaceIndexerWorker- Returns:
trueif the worker is initialized,falseotherwise
-
run
public void run() -
doRun
protected void doRun() throws IndexerException, FacetConfigServiceException, SolrServiceException, InterruptedException -
initializeSession
protected void initializeSession() -
destroySession
protected void destroySession() -
registerNonSuspendableThread
- Throws:
InterruptedException
-
getTaskName
-
logWorkerStart
protected void logWorkerStart() -
logWorkerSuccess
protected void logWorkerSuccess() -
logWorkerError
-
logWorkerInterrupted
protected void logWorkerInterrupted()
-