public class

DefaultSchedulerMessageHandlerFactory

extends Object
implements MessageHandlerFactory
java.lang.Object
   ↳ org.apache.helix.manager.zk.DefaultSchedulerMessageHandlerFactory

Summary

Nested Classes
class DefaultSchedulerMessageHandlerFactory.DefaultSchedulerMessageHandler  
class DefaultSchedulerMessageHandlerFactory.SchedulerAsyncCallback  
Constants
String CONTROLLER_MSG_ID
String SCHEDULER_MSG_ID
String SCHEDULER_TASK_QUEUE
int TASKQUEUE_BUCKET_NUM
String WAIT_ALL
Public Constructors
DefaultSchedulerMessageHandlerFactory(HelixManager manager)
Public Methods
MessageHandler createHandler(Message message, NotificationContext context)
String getMessageType()
void reset()
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.helix.messaging.handling.MessageHandlerFactory

Constants

public static final String CONTROLLER_MSG_ID

Constant Value: "controllerMsgId"

public static final String SCHEDULER_MSG_ID

Constant Value: "SchedulerMessageId"

public static final String SCHEDULER_TASK_QUEUE

Constant Value: "SchedulerTaskQueue"

public static final int TASKQUEUE_BUCKET_NUM

Constant Value: 10 (0x0000000a)

public static final String WAIT_ALL

Constant Value: "WAIT_ALL"

Public Constructors

public DefaultSchedulerMessageHandlerFactory (HelixManager manager)

Public Methods

public MessageHandler createHandler (Message message, NotificationContext context)

public String getMessageType ()

public void reset ()