Package org.apache.solr.crossdc.manager.messageprocessor

Class SolrMessageProcessor

java.lang.Object

org.apache.solr.crossdc.manager.messageprocessor.MessageProcessor

org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

All Implemented Interfaces:

IQueueHandler<MirroredSolrRequest<?>>

public class SolrMessageProcessor
extends MessageProcessor
implements IQueueHandler<MirroredSolrRequest<?>>

Message processor implements all the logic to process a MirroredSolrRequest. It handles:

• Sending the update request to Solr
• Discarding or retrying failed requests
• Flagging requests for resubmission by the underlying consumer implementation

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.crossdc.common.IQueueHandler

IQueueHandler.Result<T>, IQueueHandler.ResultStatus

Constructor Summary

Constructors

Constructor	Description
SolrMessageProcessor(Supplier<org.apache.solr.client.solrj.impl.CloudSolrClient> clientSupplier, ResubmitBackoffPolicy resubmitBackoffPolicy)

Method Summary

Modifier and Type	Method	Description
IQueueHandler.Result<MirroredSolrRequest<?>>	handleItem(MirroredSolrRequest<?> mirroredSolrRequest)
void	uncheckedSleep(long millis)

Methods inherited from class org.apache.solr.crossdc.manager.messageprocessor.MessageProcessor

getResubmitBackoffPolicy

Methods inherited from class java.lang.Object

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

Constructor Details

SolrMessageProcessor

public SolrMessageProcessor(Supplier<org.apache.solr.client.solrj.impl.CloudSolrClient> clientSupplier,
 ResubmitBackoffPolicy resubmitBackoffPolicy)

Method Details

handleItem

public IQueueHandler.Result<MirroredSolrRequest<?>> handleItem(MirroredSolrRequest<?> mirroredSolrRequest)

Specified by:

handleItem in interface IQueueHandler<MirroredSolrRequest<?>>

uncheckedSleep

public void uncheckedSleep(long millis)