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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CompletableFuture<?>completion()protected voiddoStart(ConfigurationPropertySource propertySource)protected voiddoStop()protected voiddoSubmit(LuceneBatchedWork<?> work, OperationSubmitter operationSubmitter)voidforceCommitInCurrentThread()Force a commit immediately.voidforceRefreshInCurrentThread()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:LuceneSerialWorkOrchestratorForce a commit immediately.The commit will be executed in the current thread.
- Specified by:
forceCommitInCurrentThreadin interfaceLuceneSerialWorkOrchestrator
-
forceRefreshInCurrentThread
public void forceRefreshInCurrentThread()
Description copied from interface:LuceneSerialWorkOrchestratorForce a refresh immediately.The refresh will be executed in the current thread.
- Specified by:
forceRefreshInCurrentThreadin interfaceLuceneSerialWorkOrchestrator
-
doStart
protected void doStart(ConfigurationPropertySource propertySource)
- Specified by:
doStartin classAbstractWorkOrchestrator<LuceneBatchedWork<?>>
-
doSubmit
protected void doSubmit(LuceneBatchedWork<?> work, OperationSubmitter operationSubmitter) throws InterruptedException
- Specified by:
doSubmitin classAbstractWorkOrchestrator<LuceneBatchedWork<?>>- Throws:
InterruptedException
-
completion
protected CompletableFuture<?> completion()
- Specified by:
completionin classAbstractWorkOrchestrator<LuceneBatchedWork<?>>
-
doStop
protected void doStop()
- Specified by:
doStopin classAbstractWorkOrchestrator<LuceneBatchedWork<?>>
-
-