Uses of Interface
com.broadleafcommerce.search.index.core.queue.ReindexQueue

Packages that use ReindexQueue

Package	Description
com.broadleafcommerce.search.index.core.master
com.broadleafcommerce.search.index.core.queue
com.broadleafcommerce.search.index.core.worker

Uses of ReindexQueue in com.broadleafcommerce.search.index.core.master

Methods in com.broadleafcommerce.search.index.core.master with parameters of type ReindexQueue

Modifier and Type	Method	Description
protected void	GenericSearchIndexMasterProcessLauncher.destroyQueue(ReindexQueue<T> queue)	Attempts to destroy the queue.
protected long	GenericSearchIndexMasterProcessLauncher.process(ReindexQueue<T> queue, ProcessStateHolder stateHolder)	Method to populate the ReindexQueue with data.

Uses of ReindexQueue in com.broadleafcommerce.search.index.core.queue

Classes in com.broadleafcommerce.search.index.core.queue that implement ReindexQueue

Modifier and Type	Class	Description
class	AbstractDelegatingQueue<T>	Abstract implementation of a ReindexQueue that delegates its work to any implementation of a BlockingQueue.
class	DefaultLocalArrayBlockingDelegatingQueue<T>	Default non-distributed implementation of AbstractDelegatingQueue, backed by an ArrayBlockingQueue.

Methods in com.broadleafcommerce.search.index.core.queue that return ReindexQueue

Modifier and Type	Method	Description
protected abstract <T> ReindexQueue<T>	AbstractQueueProvider.createQueue(com.broadleafcommerce.search.api.type.IndexableType type)	Create a new queue for the given IndexableType.
protected <T> ReindexQueue<T>	DefaultLocalQueueProvider.createQueue(com.broadleafcommerce.search.api.type.IndexableType type)
final <T> ReindexQueue<T>	AbstractQueueProvider.getOrCreateQueue(@NonNull com.broadleafcommerce.search.api.type.IndexableType type)
<T> ReindexQueue<T>	QueueProvider.getOrCreateQueue(com.broadleafcommerce.search.api.type.IndexableType type)	Get the Queue for the given IndexableType.

Methods in com.broadleafcommerce.search.index.core.queue that return types with arguments of type ReindexQueue

Modifier and Type	Method	Description
protected final Map<com.broadleafcommerce.search.api.type.IndexableType,ReindexQueue<?>>	AbstractQueueProvider.getQueueRegistry()	Get the registry map registering ReindexQueue to IndexableType.

Methods in com.broadleafcommerce.search.index.core.queue with parameters of type ReindexQueue

Modifier and Type	Method	Description
final void	AbstractQueueProvider.destroyQueue(ReindexQueue<?> queue)
void	QueueProvider.destroyQueue(ReindexQueue<?> queue)	Takes the necessary steps to remove or destroy the Queue, if necessary.
protected abstract void	AbstractQueueProvider.destroyQueueInternal(ReindexQueue<?> queue)	Takes the necessary steps to remove or destroy the Queue, if necessary.
protected void	DefaultLocalQueueProvider.destroyQueueInternal(ReindexQueue<?> queue)
final long	AbstractQueueLoader.populateQueue(ReindexQueue<TO> queue, ProcessStateHolder processStateHolder)
long	QueueLoader.populateQueue(ReindexQueue<T> queue, ProcessStateHolder processStateHolder)	Reads T from a source (e.g.

Uses of ReindexQueue in com.broadleafcommerce.search.index.core.worker

Methods in com.broadleafcommerce.search.index.core.worker that return ReindexQueue

Modifier and Type	Method	Description
protected ReindexQueue<T>	AbstractWorker.getQueue()

Methods in com.broadleafcommerce.search.index.core.worker with parameters of type ReindexQueue

Modifier and Type	Method	Description
protected abstract AbstractWorker<T>	GenericSearchIndexWorkerProcessLauncher.createNewTask(ProcessStateService processStateService, Semaphore semaphore, com.broadleafcommerce.search.api.type.IndexableType type, ReindexQueue<T> queue)	Launch a worker process.

Constructors in com.broadleafcommerce.search.index.core.worker with parameters of type ReindexQueue

Modifier	Constructor	Description
protected	AbstractWorker(@NonNull ProcessStateService processStateService, @NonNull Semaphore semaphore, @NonNull com.broadleafcommerce.search.api.type.IndexableType type, @NonNull ReindexQueue<T> queue, long waitTime, int maxTries)