Package org.apache.solr.cloud
Interface OverseerMessageHandler
-
- All Known Implementing Classes:
OverseerCollectionMessageHandler,OverseerConfigSetMessageHandler
public interface OverseerMessageHandlerInterface for processing messages received by anOverseerTaskProcessor
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceOverseerMessageHandler.Lock
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StringgetName()StringgetTaskKey(ZkNodeProps message)StringgetTimerName(String operation)OverseerMessageHandler.LocklockTask(ZkNodeProps message, OverseerTaskProcessor.TaskBatch taskBatch)Try to provide an exclusive lock for this particular task return null if locking is not possible.OverseerSolrResponseprocessMessage(ZkNodeProps message, String operation)
-
-
-
Method Detail
-
processMessage
OverseerSolrResponse processMessage(ZkNodeProps message, String operation)
- Parameters:
message- the message to processoperation- the operation to process- Returns:
- response
-
getName
String getName()
- Returns:
- the name of the OverseerMessageHandler
-
getTimerName
String getTimerName(String operation)
- Parameters:
operation- the operation to be timed- Returns:
- the name of the timer to use for the operation
-
lockTask
OverseerMessageHandler.Lock lockTask(ZkNodeProps message, OverseerTaskProcessor.TaskBatch taskBatch)
Try to provide an exclusive lock for this particular task return null if locking is not possible. If locking is not necessary
-
getTaskKey
String getTaskKey(ZkNodeProps message)
- Parameters:
message- the message being processed- Returns:
- the taskKey for the message for handling task exclusivity
-
-