org.broadleafcommerce.core.search.service.solr.indexer

Class ReindexStateHolder

java.lang.Object

org.broadleafcommerce.core.search.service.solr.indexer.ReindexStateHolder

public class ReindexStateHolder
extends Object

Holder to contain cross-thread state during Solr reindexing.

Author:

Kelly Tisdell

Method Summary

Modifier and Type	Method and Description
void	failFast(Exception t)
Map<String,Object>	getAdditionalState()
String	getCollectionName()
Exception	getFailure()
long	getIndexableCount()
static ReindexStateHolder	getInstance(String collectionName) Returns a shared instance of this class or null.
static ReindexStateHolder	getInstance(String collectionName, boolean incrementalCommits, boolean createIfAbsent) Creates or returns a shared instance of this class associated with the collectionName.
long	getLastCommitted()
long	getUnindexedItemCount()
long	incrementIndexableCount(long delta)
long	incrementUnindexedItemCount(long delta)
boolean	isFailed()
boolean	isIncrementalCommits()
void	setLastCommitted(long lastCommitted)
static void	unregister(String collectionName)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static ReindexStateHolder getInstance(String collectionName)

Returns a shared instance of this class or null. This method will typically be used by background worker threads that will use an instance that has already been created. This may return null if an instance has not yet been created by the control thread or the control thread has already deregistered the instance by calling deregister.

Parameters:

collectionName -

Returns:

getInstance

public static ReindexStateHolder getInstance(String collectionName,
                                             boolean incrementalCommits,
                                             boolean createIfAbsent)

Creates or returns a shared instance of this class associated with the collectionName. If createIfAbsent is set to false, this will return null if an instance has not been created. The argument for incrementalCommits is a hint indicating that commits may be issued during a reindex process. This argument is ignored if an instance has already been created. This method will typically be used by a control thread that will create a new instance for a process that may be multi-threaded.

Parameters:

collectionName -

incrementalCommits -

createIfAbsent -

Returns:

unregister

public static void unregister(String collectionName)

getCollectionName

public String getCollectionName()

isIncrementalCommits

public boolean isIncrementalCommits()

isFailed

public boolean isFailed()

failFast

public void failFast(Exception t)

getFailure

public Exception getFailure()

getIndexableCount

public long getIndexableCount()

incrementIndexableCount

public long incrementIndexableCount(long delta)

getUnindexedItemCount

public long getUnindexedItemCount()

incrementUnindexedItemCount

public long incrementUnindexedItemCount(long delta)

getAdditionalState

public Map<String,Object> getAdditionalState()

getLastCommitted

public long getLastCommitted()

setLastCommitted

public void setLastCommitted(long lastCommitted)