Package org.apache.solr.update.processor

Class RecordingUpdateProcessorFactory

java.lang.Object

org.apache.solr.update.processor.UpdateRequestProcessorFactory

org.apache.solr.update.processor.RecordingUpdateProcessorFactory

All Implemented Interfaces:

org.apache.solr.util.plugin.NamedListInitializedPlugin

public final class RecordingUpdateProcessorFactory
extends org.apache.solr.update.processor.UpdateRequestProcessorFactory

This Factory can optionally save references to the commands it receives in BlockingQueues that tests can poll from to observe that the expected commands are executed. By default, this factory does nothing except return the "next" processor from the chain unless it's told to startRecording()

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.update.processor.UpdateRequestProcessorFactory

org.apache.solr.update.processor.UpdateRequestProcessorFactory.RunAlways

Field Summary

Fields

Modifier and Type	Field	Description
BlockingQueue<org.apache.solr.update.UpdateCommand>	commandQueue	The queue containing commands that were recorded

Constructor Summary

Constructors

Constructor	Description
RecordingUpdateProcessorFactory()

Method Summary

Modifier and Type	Method	Description
org.apache.solr.update.processor.UpdateRequestProcessor	getInstance(org.apache.solr.request.SolrQueryRequest req, org.apache.solr.response.SolrQueryResponse rsp, org.apache.solr.update.processor.UpdateRequestProcessor next)
void	startRecording()
void	stopRecording()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.solr.util.plugin.NamedListInitializedPlugin

init

Field Detail

commandQueue

public final BlockingQueue<org.apache.solr.update.UpdateCommand> commandQueue

The queue containing commands that were recorded

See Also:

startRecording()

Constructor Detail

RecordingUpdateProcessorFactory

public RecordingUpdateProcessorFactory()

Method Detail

startRecording

public void startRecording()

See Also:

stopRecording(), commandQueue

stopRecording

public void stopRecording()

See Also:

startRecording()

getInstance

public org.apache.solr.update.processor.UpdateRequestProcessor getInstance(org.apache.solr.request.SolrQueryRequest req,
                                                                           org.apache.solr.response.SolrQueryResponse rsp,
                                                                           org.apache.solr.update.processor.UpdateRequestProcessor next)

Specified by:

getInstance in class org.apache.solr.update.processor.UpdateRequestProcessorFactory