Package de.hybris.platform.solrfacetsearch.indexer.workers.impl

Class DefaultIndexerWorker

java.lang.Object

de.hybris.platform.solrfacetsearch.indexer.workers.impl.DefaultIndexerWorker

All Implemented Interfaces:

IndexerWorker, Runnable

public class DefaultIndexerWorker
extends Object
implements IndexerWorker

Default implementation of IndexerWorker.

Constructor Summary

Constructors

Constructor	Description
DefaultIndexerWorker()

Method Summary

Modifier and Type	Method	Description
protected void	destroySession()
protected void	doRun()
CommonI18NService	getCommonI18NService()
FacetSearchConfigService	getFacetSearchConfigService()
IndexerBatchStrategyFactory	getIndexerBatchStrategyFactory()
SessionService	getSessionService()
SolrSearchProviderFactory	getSolrSearchProviderFactory()
protected String	getTaskName()
UserService	getUserService()
void	initialize(IndexerWorkerParameters workerParameters)	Initializes the worker.
protected void	initializeSession()
boolean	isInitialized()	Indicates if the worker is initialized and ready to run.
protected void	logWorkerError(Exception exception)
protected void	logWorkerInterrupted()
protected void	logWorkerStart()
protected void	logWorkerSuccess()
protected void	registerNonSuspendableThread()
void	run()
void	setCommonI18NService(CommonI18NService commonI18NService)
void	setFacetSearchConfigService(FacetSearchConfigService facetSearchConfigService)
void	setIndexerBatchStrategyFactory(IndexerBatchStrategyFactory indexerBatchStrategyFactory)
void	setSessionService(SessionService sessionService)
void	setSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory)
void	setUserService(UserService userService)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultIndexerWorker

public DefaultIndexerWorker()

Method Details

getSessionService

public SessionService getSessionService()

setSessionService

public void setSessionService(SessionService sessionService)

getUserService

public UserService getUserService()

setUserService

public void setUserService(UserService userService)

getCommonI18NService

public CommonI18NService getCommonI18NService()

setCommonI18NService

public void setCommonI18NService(CommonI18NService commonI18NService)

getFacetSearchConfigService

public FacetSearchConfigService getFacetSearchConfigService()

setFacetSearchConfigService

public void setFacetSearchConfigService(FacetSearchConfigService facetSearchConfigService)

getIndexerBatchStrategyFactory

public IndexerBatchStrategyFactory getIndexerBatchStrategyFactory()

setIndexerBatchStrategyFactory

public void setIndexerBatchStrategyFactory(IndexerBatchStrategyFactory indexerBatchStrategyFactory)

getSolrSearchProviderFactory

public SolrSearchProviderFactory getSolrSearchProviderFactory()

setSolrSearchProviderFactory

public void setSolrSearchProviderFactory(SolrSearchProviderFactory solrSearchProviderFactory)

initialize

public void initialize(IndexerWorkerParameters workerParameters)

Description copied from interface: IndexerWorker

Initializes the worker.

Specified by:

initialize in interface IndexerWorker

Parameters:

workerParameters - the worker parameters

isInitialized

public boolean isInitialized()

Description copied from interface: IndexerWorker

Indicates if the worker is initialized and ready to run.

Specified by:

isInitialized in interface IndexerWorker

Returns:

true if the worker is initialized, false otherwise

run

public void run()

Specified by:

run in interface Runnable

doRun

protected void doRun()
              throws IndexerException,
FacetConfigServiceException,
SolrServiceException,
InterruptedException

Throws:

IndexerException

FacetConfigServiceException

SolrServiceException

InterruptedException

initializeSession

protected void initializeSession()

destroySession

protected void destroySession()

registerNonSuspendableThread

protected void registerNonSuspendableThread()
                                     throws InterruptedException

Throws:

InterruptedException

getTaskName

protected String getTaskName()

logWorkerStart

protected void logWorkerStart()

logWorkerSuccess

protected void logWorkerSuccess()

logWorkerError

protected void logWorkerError(Exception exception)

logWorkerInterrupted

protected void logWorkerInterrupted()