Package com.broadleafcommerce.search.index.catalog.worker

Class ProductSearchIndexWorkerProcessLauncher<T>

java.lang.Object

com.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher<T>

com.broadleafcommerce.search.index.catalog.worker.ProductSearchIndexWorkerProcessLauncher<T>

Type Parameters:

T - The type of the objects retrieved from the Queue

All Implemented Interfaces:

com.broadleafcommerce.search.index.core.IndexableTypeAware, com.broadleafcommerce.search.index.core.worker.SearchIndexWorkerProcessLauncher, Runnable

public abstract class ProductSearchIndexWorkerProcessLauncher<T>
extends com.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher<T>

Executes worker threads to read and index PRODUCTs from the Queue.

Constructor Summary

Constructors

Constructor	Description
ProductSearchIndexWorkerProcessLauncher(com.broadleafcommerce.search.index.core.ProcessStateService processStateService, com.broadleafcommerce.search.index.core.queue.QueueProvider queueProvider, int threads, long waitTime, int maxTries)

Method Summary

Methods inherited from class com.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher

createExecutor, createNewTask, destroyExecutor, executeInternally, getIndexableType, getMaxTries, getProcessStateService, getQueueProvider, getWaitTime, getWorkerThreads, instance, isActive, isExecuting, launchWorkers, registerSearchIndexWorkerProcessLauncher, run

Methods inherited from class java.lang.Object

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

Constructor Detail

ProductSearchIndexWorkerProcessLauncher

public ProductSearchIndexWorkerProcessLauncher(com.broadleafcommerce.search.index.core.ProcessStateService processStateService,
                                               com.broadleafcommerce.search.index.core.queue.QueueProvider queueProvider,
                                               int threads,
                                               long waitTime,
                                               int maxTries)