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(SnIndexerBatchContext indexerBatchContext, Integer totalItems, Integer processedItems, SnIndexerOperationStatus status, SnDocumentBatchRequest documentBatchRequest, SnDocumentBatchResponse documentBatchResponse) protected abstract SnIndexerBatchResponsedoExecute(SnIndexerBatchContext indexerBatchContext, String indexerBatchId) execute(SnIndexerBatchRequest indexerBatchRequest) Executes the indexer request.protected voidexecuteAfterIndexBatchErrorListeners(SnIndexerBatchContext indexerBatchContext, List<SnIndexerBatchListener> listeners) protected voidexecuteAfterIndexBatchListeners(SnIndexerBatchContext indexerBatchContext, List<SnIndexerBatchListener> listeners) protected voidexecuteBeforeIndexBatchListeners(SnIndexerBatchContext indexerBatchContext, List<SnIndexerBatchListener> listeners) voidsetSnIndexerBatchContextFactory(SnIndexerBatchContextFactory snIndexerBatchContextFactory) 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(SnIndexerBatchContext indexerBatchContext, List<SnIndexerBatchListener> listeners) throws SnException - Throws:
SnException
-
executeAfterIndexBatchListeners
protected void executeAfterIndexBatchListeners(SnIndexerBatchContext indexerBatchContext, List<SnIndexerBatchListener> listeners) throws SnException - Throws:
SnException
-
executeAfterIndexBatchErrorListeners
protected void executeAfterIndexBatchErrorListeners(SnIndexerBatchContext indexerBatchContext, List<SnIndexerBatchListener> listeners) -
doExecute
protected abstract SnIndexerBatchResponse doExecute(SnIndexerBatchContext indexerBatchContext, String indexerBatchId) throws SnException, InterruptedException - Throws:
SnExceptionInterruptedException
-
createIndexerBatchResponse
protected SnIndexerBatchResponse createIndexerBatchResponse(SnIndexerBatchContext indexerBatchContext, Integer totalItems, Integer processedItems, SnIndexerOperationStatus status, SnDocumentBatchRequest documentBatchRequest, SnDocumentBatchResponse documentBatchResponse) -
getSnSessionService
-
setSnSessionService
-
getSnIndexerBatchContextFactory
-
setSnIndexerBatchContextFactory
public void setSnIndexerBatchContextFactory(SnIndexerBatchContextFactory snIndexerBatchContextFactory) -
getSnListenerFactory
-
setSnListenerFactory
-