Class AbstractSnIndexerBatchStrategy
java.lang.Object
de.hybris.platform.searchservices.indexer.service.impl.AbstractSnIndexerBatchStrategy
- All Implemented Interfaces:
SnIndexerBatchStrategy
- Direct Known Subclasses:
DefaultSnIndexerBatchStrategy
public abstract class AbstractSnIndexerBatchStrategy
extends Object
implements SnIndexerBatchStrategy
Base class for
SnIndexerBatchStrategy implementations.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected SnIndexerBatchResponsecreateIndexerBatchResponse(SnIndexerContext indexerContext, Integer totalItems, Integer processedItems, SnIndexerOperationStatus status) protected abstract SnIndexerBatchResponsedoExecute(SnIndexerContext indexerContext, String indexerBatchId) execute(SnIndexerBatchRequest indexerBatchRequest) Executes the indexer request.protected voidexecuteAfterIndexBatchErrorListeners(SnIndexerContext indexerContext, List<SnIndexerBatchListener> listeners) protected voidexecuteAfterIndexBatchListeners(SnIndexerContext indexerContext, List<SnIndexerBatchListener> listeners) protected voidexecuteBeforeIndexBatchListeners(SnIndexerContext indexerContext, List<SnIndexerBatchListener> listeners) voidsetSnIndexerContextFactory(SnIndexerContextFactory snIndexerContextFactory) voidsetSnListenerFactory(SnListenerFactory snListenerFactory) voidsetSnSessionService(SnSessionService snSessionService)
-
Constructor Details
-
AbstractSnIndexerBatchStrategy
public AbstractSnIndexerBatchStrategy()
-
-
Method Details
-
execute
public SnIndexerBatchResponse execute(SnIndexerBatchRequest indexerBatchRequest) throws SnIndexerException, InterruptedException Description copied from interface:SnIndexerBatchStrategyExecutes the indexer request.- Specified by:
executein interfaceSnIndexerBatchStrategy- Returns:
- the indexer batch response
- Throws:
SnIndexerException- if an error occursInterruptedException
-
executeBeforeIndexBatchListeners
protected void executeBeforeIndexBatchListeners(SnIndexerContext indexerContext, List<SnIndexerBatchListener> listeners) throws SnException - Throws:
SnException
-
executeAfterIndexBatchListeners
protected void executeAfterIndexBatchListeners(SnIndexerContext indexerContext, List<SnIndexerBatchListener> listeners) throws SnException - Throws:
SnException
-
executeAfterIndexBatchErrorListeners
protected void executeAfterIndexBatchErrorListeners(SnIndexerContext indexerContext, List<SnIndexerBatchListener> listeners) -
doExecute
protected abstract SnIndexerBatchResponse doExecute(SnIndexerContext indexerContext, String indexerBatchId) throws SnException, InterruptedException - Throws:
SnExceptionInterruptedException
-
createIndexerBatchResponse
protected SnIndexerBatchResponse createIndexerBatchResponse(SnIndexerContext indexerContext, Integer totalItems, Integer processedItems, SnIndexerOperationStatus status) -
getSnSessionService
-
setSnSessionService
-
getSnIndexerContextFactory
-
setSnIndexerContextFactory
-
getSnListenerFactory
-
setSnListenerFactory
-