Class DefaultCustomerQueueLoader
-
- All Implemented Interfaces:
com.broadleafcommerce.search.index.core.IndexableTypeAware
,com.broadleafcommerce.search.index.core.queue.QueueLoader<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
,CustomerQueueLoader<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
public class DefaultCustomerQueueLoader extends com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader<String,com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>> implements CustomerQueueLoader<com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>
Handles readingCustomer
IDs into the queue for future retrieval.
-
-
Constructor Summary
Constructors Constructor Description DefaultCustomerQueueLoader(long waitTime, int maxTries, int batchReadSize, int chunkSize, CustomerService customerService, com.broadleafcommerce.search.index.core.ProcessStateService processStateService)
-
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
-
DefaultCustomerQueueLoader
public DefaultCustomerQueueLoader(long waitTime, int maxTries, int batchReadSize, int chunkSize, CustomerService customerService, com.broadleafcommerce.search.index.core.ProcessStateService processStateService)
-
-