Package com.broadleafcommerce.search.index.customer.worker

Class CustomerSearchIndexWorkerProcessLauncher<T>

java.lang.Object

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

com.broadleafcommerce.search.index.customer.worker.CustomerSearchIndexWorkerProcessLauncher<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 CustomerSearchIndexWorkerProcessLauncher<T>
extends com.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher<T>

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

Constructor Summary

Constructors

Constructor	Description
CustomerSearchIndexWorkerProcessLauncher(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

CustomerSearchIndexWorkerProcessLauncher

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