Package org.apache.solr.cloud
Interface OverseerMessageHandler
-
- All Known Implementing Classes:
OverseerCollectionMessageHandler
,OverseerConfigSetMessageHandler
public interface OverseerMessageHandler
Interface for processing messages received by anOverseerTaskProcessor
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
OverseerMessageHandler.Lock
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description String
getName()
String
getTaskKey(ZkNodeProps message)
String
getTimerName(String operation)
OverseerMessageHandler.Lock
lockTask(ZkNodeProps message, long batchSessionId)
Grabs an exclusive lock for this particular task.OverseerSolrResponse
processMessage(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, long batchSessionId)
Grabs an exclusive lock for this particular task.- Returns:
null
if locking is not possible.
-
getTaskKey
String getTaskKey(ZkNodeProps message)
- Parameters:
message
- the message being processed- Returns:
- the taskKey for the message for handling task exclusivity
-
-