Package com.broadleafcommerce.search.index.customer.queue

Class DefaultCustomerQueueLoader

java.lang.Object

com.broadleafcommerce.search.index.core.queue.AbstractQueueLoader<ID,T>

com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader<String,com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>

com.broadleafcommerce.search.index.customer.queue.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 reading Customer 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

Modifier and Type	Method	Description
protected List<String>	readPagedIds(String startId, int batchSize)	Deprecated. in favor of readPagedIds(String, int, Map<String, Object>) for the potential to utilize additional properties when reading customers.
protected List<String>	readPagedIds(String startId, int batchSize, Map<String,Object> additionalProperties)

Methods inherited from class com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader

countIndexablesToProcess, getIndexableType, initialize, readPage, readPage, transform

Methods inherited from class com.broadleafcommerce.search.index.core.queue.AbstractQueueLoader

createExecutor, destroyExecutor, getMaxTries, getWaitTime, isRunning, populateQueue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.broadleafcommerce.search.index.core.queue.QueueLoader

populateQueue

Constructor Details

DefaultCustomerQueueLoader

public DefaultCustomerQueueLoader(long waitTime,
 int maxTries,
 int batchReadSize,
 int chunkSize,
 CustomerService customerService,
 com.broadleafcommerce.search.index.core.ProcessStateService processStateService)

Method Details

readPagedIds

@Deprecated(since="2.1.5-GA")
protected List<String> readPagedIds(@Nullable
 String startId,
 int batchSize)
                             throws com.broadleafcommerce.search.api.SearchIndexException

Deprecated.

in favor of readPagedIds(String, int, Map<String, Object>) for the potential to utilize additional properties when reading customers.

Specified by:

readPagedIds in class com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader<String,com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>

Throws:

com.broadleafcommerce.search.api.SearchIndexException

readPagedIds

protected List<String> readPagedIds(@Nullable
 String startId,
 int batchSize,
 @Nullable
 Map<String,Object> additionalProperties)
                             throws com.broadleafcommerce.search.api.SearchIndexException

Specified by:

readPagedIds in class com.broadleafcommerce.search.index.core.queue.AbstractBatchIdQueueLoader<String,com.broadleafcommerce.search.index.core.queue.BatchIdHolder<String>>

Throws:

com.broadleafcommerce.search.api.SearchIndexException