Package org.hibernate.search.mapper.pojo.massindexing.impl

Class PojoMassIndexingEntityLoadingRunnable<E,I>

java.lang.Object

org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingFailureHandledRunnable

org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingEntityLoadingRunnable<E,I>

All Implemented Interfaces:

Runnable

public class PojoMassIndexingEntityLoadingRunnable<E,I>
extends PojoMassIndexingFailureHandledRunnable

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PojoMassIndexingEntityLoadingRunnable(PojoMassIndexingNotifier notifier, PojoMassIndexingContext massIndexingContext, MassIndexingEnvironment environment, PojoMassIndexingIndexedTypeGroup<E> typeGroup, PojoMassLoadingStrategy<E,I> loadingStrategy, PojoProducerConsumerQueue<List<I>> identifierQueue, String tenantId)

Method Summary

Modifier and Type	Method	Description
protected void	cleanUpOnFailure()
protected void	cleanUpOnInterruption()
protected MassIndexingEnvironment.Context	createMassIndexingEnvironmentContext()
protected String	operationName()
protected void	runWithFailureHandler()
protected boolean	supportsThreadLifecycleHooks()

Methods inherited from class org.hibernate.search.mapper.pojo.massindexing.impl.PojoMassIndexingFailureHandledRunnable

afterExecution, beforeExecution, getMassIndexingEnvironment, getNotifier, notifyError, notifyFailure, notifyInterrupted, notifySuccess, run

Methods inherited from class java.lang.Object

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

Constructor Details

PojoMassIndexingEntityLoadingRunnable

protected PojoMassIndexingEntityLoadingRunnable(PojoMassIndexingNotifier notifier,
 PojoMassIndexingContext massIndexingContext,
 MassIndexingEnvironment environment,
 PojoMassIndexingIndexedTypeGroup<E> typeGroup,
 PojoMassLoadingStrategy<E,I> loadingStrategy,
 PojoProducerConsumerQueue<List<I>> identifierQueue,
 String tenantId)

Method Details

runWithFailureHandler

protected void runWithFailureHandler()
                              throws InterruptedException

Specified by:

runWithFailureHandler in class PojoMassIndexingFailureHandledRunnable

Throws:

InterruptedException

cleanUpOnFailure

protected void cleanUpOnFailure()

Specified by:

cleanUpOnFailure in class PojoMassIndexingFailureHandledRunnable

cleanUpOnInterruption

protected void cleanUpOnInterruption()

Specified by:

cleanUpOnInterruption in class PojoMassIndexingFailureHandledRunnable

createMassIndexingEnvironmentContext

protected MassIndexingEnvironment.Context createMassIndexingEnvironmentContext()

Overrides:

createMassIndexingEnvironmentContext in class PojoMassIndexingFailureHandledRunnable

supportsThreadLifecycleHooks

protected boolean supportsThreadLifecycleHooks()

Overrides:

supportsThreadLifecycleHooks in class PojoMassIndexingFailureHandledRunnable

operationName

protected String operationName()

Overrides:

operationName in class PojoMassIndexingFailureHandledRunnable