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 tostartRecording()
-
-
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
All Methods Instance Methods Concrete Methods 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()
-
-
-
Field Detail
-
commandQueue
public final BlockingQueue<org.apache.solr.update.UpdateCommand> commandQueue
The queue containing commands that were recorded- See Also:
startRecording()
-
-
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 classorg.apache.solr.update.processor.UpdateRequestProcessorFactory
-
-