Class DefaultProductQueueLoader
-
- All Implemented Interfaces:
ProductQueueLoader<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
,com.broadleafcommerce.search.index.core.IndexableTypeAware
,com.broadleafcommerce.search.index.core.queue.QueueLoader<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
public class DefaultProductQueueLoader extends com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader<String,com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> implements ProductQueueLoader<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
Handles readingProduct
IDs into the queue for future retrieval.
-
-
Constructor Summary
Constructors Constructor Description DefaultProductQueueLoader(long waitTime, int maxTries, int batchReadSize, int chunkSize, CatalogService catalogService, com.broadleafcommerce.search.index.core.ProcessStateService stateService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected List<String>
readPagedIds(String startId, int batchSize)
-
Methods inherited from class com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader
countIndexablesToProcess, getIndexableType, initialize, readPage, transform
-
Methods inherited from class com.broadleafcommerce.search.index.core.queue.AbstractQueueLoader
createExecutor, destroyExecutor, getMaxTries, getWaitTime, isRunning, populateQueue
-
-
-
-
Constructor Detail
-
DefaultProductQueueLoader
public DefaultProductQueueLoader(long waitTime, int maxTries, int batchReadSize, int chunkSize, CatalogService catalogService, com.broadleafcommerce.search.index.core.ProcessStateService stateService)
-
-