Class SolrOrderFulfillmentIndexWorker
java.lang.Object
com.broadleafcommerce.search.index.core.worker.AbstractWorker<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
com.broadleafcommerce.search.index.fulfillment.solr.worker.SolrOrderFulfillmentIndexWorker
- All Implemented Interfaces:
com.broadleafcommerce.search.index.core.IndexableTypeAware
,Runnable
public class SolrOrderFulfillmentIndexWorker
extends com.broadleafcommerce.search.index.core.worker.AbstractWorker<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
- Author:
- Dima Myroniuk (dmyroniuk)
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
SolrOrderFulfillmentIndexWorker
(@NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService, @NonNull Semaphore semaphore, @NonNull com.broadleafcommerce.search.api.type.IndexableType type, @NonNull com.broadleafcommerce.search.index.core.queue.ReindexQueue<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> queue, @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, long waitTime, int maxTries) Deprecated, for removal: This API element is subject to removal in a future version.protected
SolrOrderFulfillmentIndexWorker
(@NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService, @NonNull Semaphore semaphore, @NonNull com.broadleafcommerce.search.api.type.IndexableType type, @NonNull com.broadleafcommerce.search.index.core.queue.ReindexQueue<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> queue, @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, @NonNull com.broadleafcommerce.search.index.solr.worker.SolrIndexWorkerUtil solrIndexWorkerUtil, long waitTime, int maxTries) -
Method Summary
Modifier and TypeMethodDescriptionprotected int
executeInternal
(com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String> queueEntry) protected int
executeInternal
(com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String> queueEntry, com.broadleafcommerce.search.index.core.ProcessStateHolder processStateHolder) protected com.broadleafcommerce.search.provider.solr.SolrCollectionResolver
protected com.broadleafcommerce.search.index.core.document.DocumentBuilder<org.apache.solr.common.SolrInputDocument>
protected com.broadleafcommerce.search.index.fulfillment.service.OrderFulfillmentService<com.broadleafcommerce.search.fulfillment.core.domain.OrderFulfillment>
protected com.broadleafcommerce.search.provider.solr.SolrIndexProvider
protected com.broadleafcommerce.search.index.solr.worker.SolrIndexWorkerUtil
Methods inherited from class com.broadleafcommerce.search.index.core.worker.AbstractWorker
getIndexableType, getMaxTries, getProcessStateService, getQueue, getSemaphore, getType, getWaitTime, run
-
Constructor Details
-
SolrOrderFulfillmentIndexWorker
@Deprecated(forRemoval=true, since="2.1.2, 2.0.3") protected SolrOrderFulfillmentIndexWorker(@NonNull @NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService, @NonNull @NonNull Semaphore semaphore, @NonNull @NonNull com.broadleafcommerce.search.api.type.IndexableType type, @NonNull @NonNull com.broadleafcommerce.search.index.core.queue.ReindexQueue<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> queue, @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, long waitTime, int maxTries) Deprecated, for removal: This API element is subject to removal in a future version. -
SolrOrderFulfillmentIndexWorker
protected SolrOrderFulfillmentIndexWorker(@NonNull @NonNull com.broadleafcommerce.search.index.core.ProcessStateService processStateService, @NonNull @NonNull Semaphore semaphore, @NonNull @NonNull com.broadleafcommerce.search.api.type.IndexableType type, @NonNull @NonNull com.broadleafcommerce.search.index.core.queue.ReindexQueue<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> queue, @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, @NonNull @NonNull com.broadleafcommerce.search.index.solr.worker.SolrIndexWorkerUtil solrIndexWorkerUtil, long waitTime, int maxTries)
-
-
Method Details
-
executeInternal
protected int executeInternal(com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String> queueEntry) throws com.broadleafcommerce.search.api.SearchIndexException - Specified by:
executeInternal
in classcom.broadleafcommerce.search.index.core.worker.AbstractWorker<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
- Throws:
com.broadleafcommerce.search.api.SearchIndexException
-
executeInternal
protected int executeInternal(com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String> queueEntry, com.broadleafcommerce.search.index.core.ProcessStateHolder processStateHolder) throws com.broadleafcommerce.search.api.SearchIndexException - Specified by:
executeInternal
in classcom.broadleafcommerce.search.index.core.worker.AbstractWorker<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
- Throws:
com.broadleafcommerce.search.api.SearchIndexException
-
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() -
getSolrIndexWorkerUtil
protected com.broadleafcommerce.search.index.solr.worker.SolrIndexWorkerUtil getSolrIndexWorkerUtil()
-
SolrOrderFulfillmentIndexWorker(ProcessStateService, Semaphore, IndexableType, ReindexQueue, OrderFulfillmentService, DocumentBuilder, SolrIndexProvider, SolrCollectionResolver, DataRouteSupporting, SolrIndexWorkerUtil, long, int)