Package org.apache.solr.cloud
Class OverseerConfigSetMessageHandler
- java.lang.Object
-
- org.apache.solr.cloud.OverseerConfigSetMessageHandler
-
- All Implemented Interfaces:
OverseerMessageHandler
public class OverseerConfigSetMessageHandler extends Object implements OverseerMessageHandler
AOverseerMessageHandlerthat handles ConfigSets API related overseer messages.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.solr.cloud.OverseerMessageHandler
OverseerMessageHandler.Lock
-
-
Field Summary
Fields Modifier and Type Field Description static StringCONFIGSETS_ACTION_PREFIXPrefix to specify an action should be handled by this handler.
-
Constructor Summary
Constructors Constructor Description OverseerConfigSetMessageHandler(org.apache.solr.common.cloud.ZkStateReader zkStateReader, CoreContainer coreContainer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetName()StringgetTaskKey(org.apache.solr.common.cloud.ZkNodeProps message)StringgetTimerName(String operation)OverseerMessageHandler.LocklockTask(org.apache.solr.common.cloud.ZkNodeProps message, long ignored)Grabs an exclusive lock for this particular task.OverseerSolrResponseprocessMessage(org.apache.solr.common.cloud.ZkNodeProps message, String operation)
-
-
-
Field Detail
-
CONFIGSETS_ACTION_PREFIX
public static final String CONFIGSETS_ACTION_PREFIX
Prefix to specify an action should be handled by this handler.- See Also:
- Constant Field Values
-
-
Constructor Detail
-
OverseerConfigSetMessageHandler
public OverseerConfigSetMessageHandler(org.apache.solr.common.cloud.ZkStateReader zkStateReader, CoreContainer coreContainer)
-
-
Method Detail
-
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
public String getName()
- Specified by:
getNamein interfaceOverseerMessageHandler- Returns:
- the name of the OverseerMessageHandler
-
getTimerName
public String getTimerName(String operation)
- 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
public String getTaskKey(org.apache.solr.common.cloud.ZkNodeProps message)
- Specified by:
getTaskKeyin interfaceOverseerMessageHandler- Parameters:
message- the message being processed- Returns:
- the taskKey for the message for handling task exclusivity
-
-