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

Class SolrOrderFulfillmentSearchIndexWorkerProcessLauncher

java.lang.Object

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

com.broadleafcommerce.search.index.fulfillment.worker.OrderFulfillmentSearchIndexWorkerProcessLauncher<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>

com.broadleafcommerce.search.index.fulfillment.solr.worker.SolrOrderFulfillmentSearchIndexWorkerProcessLauncher

All Implemented Interfaces:

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

public class SolrOrderFulfillmentSearchIndexWorkerProcessLauncher
extends com.broadleafcommerce.search.index.fulfillment.worker.OrderFulfillmentSearchIndexWorkerProcessLauncher<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>

Author:

Dima Myroniuk (dmyroniuk)

Constructor Summary

Constructors

Constructor

Description

SolrOrderFulfillmentSearchIndexWorkerProcessLauncher(@NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService, @NonNull com.broadleafcommerce.search.index.core.queue.QueueProvider queueProvider, @NonNull com.broadleafcommerce.search.index.fulfillment.service.OrderFulfillmentService<com.broadleafcommerce.search.fulfillment.core.domain.OrderFulfillment> orderFulfillmentService, @NonNull com.broadleafcommerce.search.index.core.document.DocumentBuilder<org.apache.solr.common.SolrInputDocument> documentBuilder, @NonNull com.broadleafcommerce.search.provider.solr.SolrIndexProvider solrIndexProvider, @NonNull com.broadleafcommerce.search.provider.solr.SolrCollectionResolver collectionResolver, com.broadleafcommerce.common.extension.data.DataRouteSupporting searchSource, int threads, long waitTime, int maxTries)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.search.index.core.worker.AbstractWorker<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>	createNewTask(com.broadleafcommerce.search.index.core.ProcessStateService processStateService, Semaphore semaphore, com.broadleafcommerce.search.api.type.IndexableType type, com.broadleafcommerce.search.index.core.queue.ReindexQueue<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> queue)
protected com.broadleafcommerce.search.provider.solr.SolrCollectionResolver	getCollectionResolver()
protected com.broadleafcommerce.search.index.core.document.DocumentBuilder<org.apache.solr.common.SolrInputDocument>	getDocumentBuilder()
protected com.broadleafcommerce.search.index.fulfillment.service.OrderFulfillmentService<com.broadleafcommerce.search.fulfillment.core.domain.OrderFulfillment>	getOrderFulfillmentService()
protected com.broadleafcommerce.search.provider.solr.SolrIndexProvider	getSolrIndexProvider()

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

createExecutor, 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

SolrOrderFulfillmentSearchIndexWorkerProcessLauncher

public SolrOrderFulfillmentSearchIndexWorkerProcessLauncher(@NonNull
                                                            @NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService,
                                                            @NonNull
                                                            @NonNull com.broadleafcommerce.search.index.core.queue.QueueProvider queueProvider,
                                                            @NonNull
                                                            @NonNull com.broadleafcommerce.search.index.fulfillment.service.OrderFulfillmentService<com.broadleafcommerce.search.fulfillment.core.domain.OrderFulfillment> orderFulfillmentService,
                                                            @NonNull
                                                            @NonNull com.broadleafcommerce.search.index.core.document.DocumentBuilder<org.apache.solr.common.SolrInputDocument> documentBuilder,
                                                            @NonNull
                                                            @NonNull com.broadleafcommerce.search.provider.solr.SolrIndexProvider solrIndexProvider,
                                                            @NonNull
                                                            @NonNull com.broadleafcommerce.search.provider.solr.SolrCollectionResolver collectionResolver,
                                                            com.broadleafcommerce.common.extension.data.DataRouteSupporting searchSource,
                                                            int threads,
                                                            long waitTime,
                                                            int maxTries)

Method Detail

createNewTask

protected com.broadleafcommerce.search.index.core.worker.AbstractWorker<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> createNewTask(com.broadleafcommerce.search.index.core.ProcessStateService processStateService,
                                                                                                                                                           Semaphore semaphore,
                                                                                                                                                           com.broadleafcommerce.search.api.type.IndexableType type,
                                                                                                                                                           com.broadleafcommerce.search.index.core.queue.ReindexQueue<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> queue)

Specified by:

createNewTask in class com.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>

getOrderFulfillmentService

protected com.broadleafcommerce.search.index.fulfillment.service.OrderFulfillmentService<com.broadleafcommerce.search.fulfillment.core.domain.OrderFulfillment> getOrderFulfillmentService()

getDocumentBuilder

protected com.broadleafcommerce.search.index.core.document.DocumentBuilder<org.apache.solr.common.SolrInputDocument> getDocumentBuilder()

getSolrIndexProvider

protected com.broadleafcommerce.search.provider.solr.SolrIndexProvider getSolrIndexProvider()

getCollectionResolver

protected com.broadleafcommerce.search.provider.solr.SolrCollectionResolver getCollectionResolver()