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

Interface SolrIndexQueueProvider

All Known Implementing Classes:

DefaultSolrIndexQueueProvider

public interface SolrIndexQueueProvider

Provides a FIFO Queue to hold a series of commands to be executed in sequence. This also provides a Lock so that only one thread can execute commands at any given time.

Note that it's safer to use a distributed Queue and a distributed Lock so that multiple nodes (JVMs) can't simultaneously execute commands, potentially overriding or corrupting each other. A local Queue and a local Lock are satisfactory if users can guarantee that only a single node (JVM) will ever update Solr or receive events (e.g. from the admin) to update Solr.

Author:

Kelly Tisdell

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COMMAND_LOCK_NAME
static final String	COMMAND_QUEUE_NAME

Method Summary

Modifier and Type	Method	Description
Lock	createOrRetrieveCommandLock(String lockName)
BlockingQueue<? super SolrUpdateCommand>	createOrRetrieveCommandQueue(String queueName)
boolean	isDistributed()

Field Details

COMMAND_LOCK_NAME

static final String COMMAND_LOCK_NAME

See Also:

• Constant Field Values

COMMAND_QUEUE_NAME

static final String COMMAND_QUEUE_NAME

See Also:

• Constant Field Values

Method Details

createOrRetrieveCommandQueue

BlockingQueue<? super SolrUpdateCommand> createOrRetrieveCommandQueue(String queueName)

createOrRetrieveCommandLock

Lock createOrRetrieveCommandLock(String lockName)

isDistributed

boolean isDistributed()