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

Class PojoMassIndexingFailureHandledRunnable

java.lang.Object

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

PojoMassIndexingBatchCoordinator, PojoMassIndexingBatchIndexingWorkspace, PojoMassIndexingEntityIdentifierLoadingRunnable, PojoMassIndexingEntityLoadingRunnable

public abstract class PojoMassIndexingFailureHandledRunnable
extends Object
implements Runnable

Common parent of all Runnable implementations for the batch indexing: share the code for handling runtime exceptions.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PojoMassIndexingFailureHandledRunnable(PojoMassIndexingNotifier notifier, MassIndexingEnvironment environment)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecution()
protected void	beforeExecution()
protected abstract void	cleanUpOnFailure()
protected abstract void	cleanUpOnInterruption()
protected MassIndexingEnvironment.Context	createMassIndexingEnvironmentContext()
protected final MassIndexingEnvironment	getMassIndexingEnvironment()
protected final PojoMassIndexingNotifier	getNotifier()
protected void	notifyError(Error error)
protected void	notifyFailure(RuntimeException exception)
protected void	notifyInterrupted(InterruptedException exception)
protected void	notifySuccess()
protected String	operationName()
final void	run()
protected abstract void	runWithFailureHandler()
protected boolean	supportsThreadLifecycleHooks()

Methods inherited from class java.lang.Object

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

Constructor Details

PojoMassIndexingFailureHandledRunnable

protected PojoMassIndexingFailureHandledRunnable(PojoMassIndexingNotifier notifier,
 MassIndexingEnvironment environment)

Method Details

run

public final void run()

Specified by:

run in interface Runnable

runWithFailureHandler

protected abstract void runWithFailureHandler()
                                       throws InterruptedException

Throws:

InterruptedException

cleanUpOnInterruption

protected abstract void cleanUpOnInterruption()
                                       throws InterruptedException

Throws:

InterruptedException

cleanUpOnFailure

protected abstract void cleanUpOnFailure()
                                  throws InterruptedException

Throws:

InterruptedException

createMassIndexingEnvironmentContext

protected MassIndexingEnvironment.Context createMassIndexingEnvironmentContext()

supportsThreadLifecycleHooks

protected boolean supportsThreadLifecycleHooks()

beforeExecution

protected void beforeExecution()

afterExecution

protected void afterExecution()

getNotifier

protected final PojoMassIndexingNotifier getNotifier()

getMassIndexingEnvironment

protected final MassIndexingEnvironment getMassIndexingEnvironment()

notifySuccess

protected void notifySuccess()

notifyError

protected void notifyError(Error error)

notifyInterrupted

protected void notifyInterrupted(InterruptedException exception)

notifyFailure

protected void notifyFailure(RuntimeException exception)

operationName

protected String operationName()