Uses of Interface
com.broadleafcommerce.search.index.core.ProcessStateService
-
-
Uses of ProcessStateService in com.broadleafcommerce.search.index.autoconfigure
Methods in com.broadleafcommerce.search.index.autoconfigure that return ProcessStateService Modifier and Type Method Description ProcessStateService
CoreIndexerAutoConfiguration. searchReindexerProcessStateService()
-
Uses of ProcessStateService in com.broadleafcommerce.search.index.core
Classes in com.broadleafcommerce.search.index.core that implement ProcessStateService Modifier and Type Class Description class
AbstractProcessStateService
Mechanism to safely access or update process state across threads within a single JVM.class
DefaultProcessStateService
Default implementation of the ProcessStateService interface. -
Uses of ProcessStateService in com.broadleafcommerce.search.index.core.event.listener
Methods in com.broadleafcommerce.search.index.core.event.listener that return ProcessStateService Modifier and Type Method Description protected ProcessStateService
BatchCompletedEventListener. getProcessStateService()
protected ProcessStateService
ProcessCompleteEventListener. getProcessStateService()
protected ProcessStateService
ProcessFailedEventListener. getProcessStateService()
protected ProcessStateService
ProcessStartedEventListener. getProcessStateService()
Constructors in com.broadleafcommerce.search.index.core.event.listener with parameters of type ProcessStateService Constructor Description BatchCompletedEventListener(ProcessStateService processStateService)
ProcessCompleteEventListener(ProcessStateService processStateService)
ProcessFailedEventListener(ProcessStateService processStateService)
ProcessStartedEventListener(ProcessStateService processStateService)
QueueCreatedEventListener(ProcessStateService processStateService)
QueueCreatedEventListener(ProcessStateService processStateService, boolean masterIsWorker)
QueueLoadedEventListener(QueueProvider queueProvider, ProcessStateService processStateService)
WorkerCompletedEventListener(ProcessStateService processStateService, SemaphoreProvider semaphoreProvider)
WorkerStartedEventListener(ProcessStateService processStateService)
-
Uses of ProcessStateService in com.broadleafcommerce.search.index.core.master
Methods in com.broadleafcommerce.search.index.core.master that return ProcessStateService Modifier and Type Method Description protected ProcessStateService
GenericSearchIndexMasterProcessLauncher. getProcessStateService()
Constructors in com.broadleafcommerce.search.index.core.master with parameters of type ProcessStateService Constructor Description GenericSearchIndexMasterProcessLauncher(ProcessStateService processStateService, LockService lockService, QueueProvider queueProvider, QueueLoader<T> batchIdReader, SemaphoreProvider semaphoreProvider, long completionPauseTime)
-
Uses of ProcessStateService in com.broadleafcommerce.search.index.core.worker
Methods in com.broadleafcommerce.search.index.core.worker that return ProcessStateService Modifier and Type Method Description protected ProcessStateService
AbstractWorker. getProcessStateService()
protected ProcessStateService
GenericSearchIndexWorkerProcessLauncher. getProcessStateService()
Methods in com.broadleafcommerce.search.index.core.worker with parameters of type ProcessStateService Modifier and Type Method Description protected abstract AbstractWorker<T>
GenericSearchIndexWorkerProcessLauncher. createNewTask(ProcessStateService processStateService, Semaphore semaphore, com.broadleafcommerce.search.api.type.IndexableType type, ReindexQueue<T> queue)
Launch a worker process.Constructors in com.broadleafcommerce.search.index.core.worker with parameters of type ProcessStateService Constructor Description AbstractWorker(@NonNull ProcessStateService processStateService, @NonNull Semaphore semaphore, @NonNull com.broadleafcommerce.search.api.type.IndexableType type, @NonNull ReindexQueue<T> queue, long waitTime, int maxTries)
GenericSearchIndexWorkerProcessLauncher(com.broadleafcommerce.search.api.type.IndexableType indexableType, ProcessStateService processStateService, QueueProvider queueProvider, int threads, long waitTime, int maxTries)
-