public class

BatchMessageHandler

extends MessageHandler
java.lang.Object
   ↳ org.apache.helix.messaging.handling.MessageHandler
     ↳ org.apache.helix.messaging.handling.BatchMessageHandler

Summary

[Expand]
Inherited Fields
From class org.apache.helix.messaging.handling.MessageHandler
Public Constructors
BatchMessageHandler(Message msg, NotificationContext context, MessageHandlerFactory fty, BatchMessageWrapper wrapper, TaskExecutor executor)
Public Methods
HelixTaskResult handleMessage()
Message handling routine.
void onError(Exception e, MessageHandler.ErrorCode code, MessageHandler.ErrorType type)
Callback when error happens in the message handling pipeline.
void postHandleMessage()
void preHandleMessage()
[Expand]
Inherited Methods
From class org.apache.helix.messaging.handling.MessageHandler
From class java.lang.Object

Public Constructors

public BatchMessageHandler (Message msg, NotificationContext context, MessageHandlerFactory fty, BatchMessageWrapper wrapper, TaskExecutor executor)

Public Methods

public HelixTaskResult handleMessage ()

Message handling routine. The function is called in a thread pool task in CMTaskExecutor

Returns
  • returns the CMTaskResult which contains info about the message processing.

public void onError (Exception e, MessageHandler.ErrorCode code, MessageHandler.ErrorType type)

Callback when error happens in the message handling pipeline.

Parameters
type TODO

public void postHandleMessage ()

public void preHandleMessage ()