Package de.hybris.platform.searchservices.indexer.service.impl

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 java.lang.Object
implements SnIndexerBatchStrategy

Base class for SnIndexerBatchStrategy implementations.

Constructor Summary

Constructors

Constructor	Description
AbstractSnIndexerBatchStrategy()

Method Summary

Modifier and Type	Method	Description
protected SnIndexerBatchResponse	createIndexerBatchResponse(SnIndexerContext indexerContext, java.lang.Integer totalItems, java.lang.Integer processedItems, SnIndexerOperationStatus status)
protected abstract SnIndexerBatchResponse	doExecute(SnIndexerContext indexerContext, java.lang.String indexerBatchId)
SnIndexerBatchResponse	execute(SnIndexerBatchRequest indexerBatchRequest)	Executes the indexer request.
protected void	executeAfterIndexBatchErrorListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerBatchListener> listeners)
protected void	executeAfterIndexBatchListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerBatchListener> listeners)
protected void	executeBeforeIndexBatchListeners(SnIndexerContext indexerContext, java.util.List<SnIndexerBatchListener> listeners)
SnIndexerContextFactory	getSnIndexerContextFactory()
SnListenerFactory	getSnListenerFactory()
SnSessionService	getSnSessionService()
void	setSnIndexerContextFactory(SnIndexerContextFactory snIndexerContextFactory)
void	setSnListenerFactory(SnListenerFactory snListenerFactory)
void	setSnSessionService(SnSessionService snSessionService)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSnIndexerBatchStrategy

public AbstractSnIndexerBatchStrategy()

Method Detail

execute

public SnIndexerBatchResponse execute(SnIndexerBatchRequest indexerBatchRequest)
                               throws SnIndexerException,
                                      java.lang.InterruptedException

Description copied from interface: SnIndexerBatchStrategy

Executes the indexer request.

Specified by:

execute in interface SnIndexerBatchStrategy

Returns:

the indexer batch response

Throws:

SnIndexerException - if an error occurs

java.lang.InterruptedException

executeBeforeIndexBatchListeners

protected void executeBeforeIndexBatchListeners(SnIndexerContext indexerContext,
                                                java.util.List<SnIndexerBatchListener> listeners)
                                         throws SnException

Throws:

SnException

executeAfterIndexBatchListeners

protected void executeAfterIndexBatchListeners(SnIndexerContext indexerContext,
                                               java.util.List<SnIndexerBatchListener> listeners)
                                        throws SnException

Throws:

SnException

executeAfterIndexBatchErrorListeners

protected void executeAfterIndexBatchErrorListeners(SnIndexerContext indexerContext,
                                                    java.util.List<SnIndexerBatchListener> listeners)

doExecute

protected abstract SnIndexerBatchResponse doExecute(SnIndexerContext indexerContext,
                                                    java.lang.String indexerBatchId)
                                             throws SnException,
                                                    java.lang.InterruptedException

Throws:

SnException

java.lang.InterruptedException

createIndexerBatchResponse

protected SnIndexerBatchResponse createIndexerBatchResponse(SnIndexerContext indexerContext,
                                                            java.lang.Integer totalItems,
                                                            java.lang.Integer processedItems,
                                                            SnIndexerOperationStatus status)

getSnSessionService

public SnSessionService getSnSessionService()

setSnSessionService

public void setSnSessionService(SnSessionService snSessionService)

getSnIndexerContextFactory

public SnIndexerContextFactory getSnIndexerContextFactory()

setSnIndexerContextFactory

public void setSnIndexerContextFactory(SnIndexerContextFactory snIndexerContextFactory)

getSnListenerFactory

public SnListenerFactory getSnListenerFactory()

setSnListenerFactory

public void setSnListenerFactory(SnListenerFactory snListenerFactory)