Package com.broadleafcommerce.search.index.fulfillment.worker

Class OrderFulfillmentSearchIndexWorkerProcessLauncher<T>

java.lang.Object

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

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

Executes worker threads to read and index OrderFulfillmentIndexableType.ORDER_FULFILLMENT from the Queue.

Author:

Dima Myroniuk (dmyroniuk)

Constructor Summary

Constructors

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

OrderFulfillmentSearchIndexWorkerProcessLauncher

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