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

Class PojoMassIndexingEntityIdentifierLoadingRunnable<E,I>

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class PojoMassIndexingEntityIdentifierLoadingRunnable<E,I>
extends PojoMassIndexingFailureHandledRunnable

Constructor Summary

Constructors

Constructor	Description
PojoMassIndexingEntityIdentifierLoadingRunnable(PojoMassIndexingNotifier notifier, MassIndexingEnvironment environment, PojoMassIndexingIndexedTypeGroup<E> typeGroup, PojoMassIndexingLoadingStrategy<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 Detail

PojoMassIndexingEntityIdentifierLoadingRunnable

public PojoMassIndexingEntityIdentifierLoadingRunnable(PojoMassIndexingNotifier notifier,
                                                       MassIndexingEnvironment environment,
                                                       PojoMassIndexingIndexedTypeGroup<E> typeGroup,
                                                       PojoMassIndexingLoadingStrategy<E,I> loadingStrategy,
                                                       PojoProducerConsumerQueue<List<I>> identifierQueue,
                                                       String tenantId)

Method Detail

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