Package org.apache.solr.cloud
Class OverseerConfigSetMessageHandler
java.lang.Object
org.apache.solr.cloud.OverseerConfigSetMessageHandler
- All Implemented Interfaces:
OverseerMessageHandler
A
OverseerMessageHandler that handles ConfigSets API related overseer messages.-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.solr.cloud.OverseerMessageHandler
OverseerMessageHandler.Lock -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StringPrefix to specify an action should be handled by this handler. -
Constructor Summary
ConstructorsConstructorDescriptionOverseerConfigSetMessageHandler(org.apache.solr.common.cloud.ZkStateReader zkStateReader, CoreContainer coreContainer) -
Method Summary
Modifier and TypeMethodDescriptiongetName()getTaskKey(org.apache.solr.common.cloud.ZkNodeProps message) getTimerName(String operation) lockTask(org.apache.solr.common.cloud.ZkNodeProps message, long ignored) Grabs an exclusive lock for this particular task.processMessage(org.apache.solr.common.cloud.ZkNodeProps message, String operation)
-
Field Details
-
CONFIGSETS_ACTION_PREFIX
Prefix to specify an action should be handled by this handler.- See Also:
-
-
Constructor Details
-
OverseerConfigSetMessageHandler
public OverseerConfigSetMessageHandler(org.apache.solr.common.cloud.ZkStateReader zkStateReader, CoreContainer coreContainer)
-
-
Method Details
-
processMessage
public OverseerSolrResponse processMessage(org.apache.solr.common.cloud.ZkNodeProps message, String operation) - Specified by:
processMessagein interfaceOverseerMessageHandler- Parameters:
message- the message to processoperation- the operation to process- Returns:
- response
-
getName
- Specified by:
getNamein interfaceOverseerMessageHandler- Returns:
- the name of the OverseerMessageHandler
-
getTimerName
- Specified by:
getTimerNamein interfaceOverseerMessageHandler- Parameters:
operation- the operation to be timed- Returns:
- the name of the timer to use for the operation
-
lockTask
public OverseerMessageHandler.Lock lockTask(org.apache.solr.common.cloud.ZkNodeProps message, long ignored) Description copied from interface:OverseerMessageHandlerGrabs an exclusive lock for this particular task.- Specified by:
lockTaskin interfaceOverseerMessageHandler- Returns:
nullif locking is not possible.
-
getTaskKey
- Specified by:
getTaskKeyin interfaceOverseerMessageHandler- Parameters:
message- the message being processed- Returns:
- the taskKey for the message for handling task exclusivity
-