Class SolrCustomerSearchIndexWorkerProcessLauncher
- java.lang.Object
-
- com.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher<T>
-
- com.broadleafcommerce.search.index.customer.worker.CustomerSearchIndexWorkerProcessLauncher<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
-
- com.broadleafcommerce.search.index.customer.solr.worker.SolrCustomerSearchIndexWorkerProcessLauncher
-
- All Implemented Interfaces:
com.broadleafcommerce.search.index.core.IndexableTypeAware
,com.broadleafcommerce.search.index.core.worker.SearchIndexWorkerProcessLauncher
,Runnable
public class SolrCustomerSearchIndexWorkerProcessLauncher extends com.broadleafcommerce.search.index.customer.worker.CustomerSearchIndexWorkerProcessLauncher<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
-
-
Constructor Summary
Constructors Constructor Description SolrCustomerSearchIndexWorkerProcessLauncher(@NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService, @NonNull com.broadleafcommerce.search.index.core.queue.QueueProvider queueProvider, @NonNull com.broadleafcommerce.search.index.customer.service.CustomerService customerService, @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
All Methods Instance Methods Concrete Methods 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.customer.service.CustomerService
getCustomerService()
protected com.broadleafcommerce.search.index.core.document.DocumentBuilder<org.apache.solr.common.SolrInputDocument>
getDocumentBuilder()
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
-
-
-
-
Constructor Detail
-
SolrCustomerSearchIndexWorkerProcessLauncher
public SolrCustomerSearchIndexWorkerProcessLauncher(@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.customer.service.CustomerService customerService, @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 classcom.broadleafcommerce.search.index.core.worker.GenericSearchIndexWorkerProcessLauncher<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
-
getCustomerService
protected com.broadleafcommerce.search.index.customer.service.CustomerService getCustomerService()
-
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()
-
-