Package org.hibernate.search.backend.lucene.orchestration.impl

Class LuceneSerialWorkOrchestratorImpl

java.lang.Object

org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator<LuceneBatchedWork<?>>

org.hibernate.search.backend.lucene.orchestration.impl.LuceneSerialWorkOrchestratorImpl

All Implemented Interfaces:

LuceneSerialWorkOrchestrator

public class LuceneSerialWorkOrchestratorImpl
extends AbstractWorkOrchestrator<LuceneBatchedWork<?>>
implements LuceneSerialWorkOrchestrator

Field Summary

Fields inherited from class org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator

blockingRetryProducer

Constructor Summary

Constructors

Constructor	Description
LuceneSerialWorkOrchestratorImpl(String name, LuceneBatchedWorkProcessor processor, BackendThreads threads, FailureHandler failureHandler)

Method Summary

Modifier and Type	Method	Description
protected CompletableFuture<?>	completion()
protected void	doStart(ConfigurationPropertySource propertySource)
protected void	doStop()
protected void	doSubmit(LuceneBatchedWork<?> work, OperationSubmitter operationSubmitter)
void	forceCommitInCurrentThread()	Force a commit immediately.
void	forceRefreshInCurrentThread()	Force a refresh immediately.

Methods inherited from class org.hibernate.search.engine.backend.orchestration.spi.AbstractWorkOrchestrator

name, preStop, start, stop, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.search.backend.lucene.orchestration.impl.LuceneSerialWorkOrchestrator

submit, submit

Constructor Detail

LuceneSerialWorkOrchestratorImpl

public LuceneSerialWorkOrchestratorImpl(String name,
                                        LuceneBatchedWorkProcessor processor,
                                        BackendThreads threads,
                                        FailureHandler failureHandler)

Parameters:

name - The name of the orchestrator thread (and of this orchestrator when reporting errors)

processor - A processor to use in the background thread.

threads - The threads for this backend.

failureHandler - A failure handler to report failures of the background thread.

Method Detail

forceCommitInCurrentThread

public void forceCommitInCurrentThread()

Description copied from interface: LuceneSerialWorkOrchestrator

Force a commit immediately.

The commit will be executed in the current thread.

Specified by:

forceCommitInCurrentThread in interface LuceneSerialWorkOrchestrator

forceRefreshInCurrentThread

public void forceRefreshInCurrentThread()

Description copied from interface: LuceneSerialWorkOrchestrator

Force a refresh immediately.

The refresh will be executed in the current thread.

Specified by:

forceRefreshInCurrentThread in interface LuceneSerialWorkOrchestrator

doStart

protected void doStart(ConfigurationPropertySource propertySource)

Specified by:

doStart in class AbstractWorkOrchestrator<LuceneBatchedWork<?>>

doSubmit

protected void doSubmit(LuceneBatchedWork<?> work,
                        OperationSubmitter operationSubmitter)
                 throws InterruptedException

Specified by:

doSubmit in class AbstractWorkOrchestrator<LuceneBatchedWork<?>>

Throws:

InterruptedException

completion

protected CompletableFuture<?> completion()

Specified by:

completion in class AbstractWorkOrchestrator<LuceneBatchedWork<?>>

doStop

protected void doStop()

Specified by:

doStop in class AbstractWorkOrchestrator<LuceneBatchedWork<?>>