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

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

Fields

Modifier and Type	Field	Description
static String	CONFIGSETS_ACTION_PREFIX	Prefix to specify an action should be handled by this handler.

Constructor Summary

Constructors

Constructor	Description
OverseerConfigSetMessageHandler(ZkStateReader zkStateReader, CoreContainer coreContainer)

Method Summary

Modifier and Type	Method	Description
String	getName()
String	getTaskKey(ZkNodeProps message)
String	getTimerName(String operation)
OverseerMessageHandler.Lock	lockTask(ZkNodeProps message, long ignored)	Grabs an exclusive lock for this particular task.
OverseerSolrResponse	processMessage(ZkNodeProps message, String operation)

Methods inherited from class java.lang.Object

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

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(ZkStateReader zkStateReader,
                                       CoreContainer coreContainer)

Method Detail

processMessage

public OverseerSolrResponse processMessage(ZkNodeProps message,
                                           String operation)

Specified by:

processMessage in interface OverseerMessageHandler

Parameters:

message - the message to process

operation - the operation to process

Returns:

response

getName

public String getName()

Specified by:

getName in interface OverseerMessageHandler

Returns:

the name of the OverseerMessageHandler

getTimerName

public String getTimerName(String operation)

Specified by:

getTimerName in interface OverseerMessageHandler

Parameters:

operation - the operation to be timed

Returns:

the name of the timer to use for the operation

lockTask

public OverseerMessageHandler.Lock lockTask(ZkNodeProps message,
                                            long ignored)

Description copied from interface: OverseerMessageHandler

Grabs an exclusive lock for this particular task.

Specified by:

lockTask in interface OverseerMessageHandler

Returns:

null if locking is not possible.

getTaskKey

public String getTaskKey(ZkNodeProps message)

Specified by:

getTaskKey in interface OverseerMessageHandler

Parameters:

message - the message being processed

Returns:

the taskKey for the message for handling task exclusivity