| java.lang.Object | ||
| ↳ | org.apache.helix.messaging.handling.MessageHandler | |
| ↳ | org.apache.helix.messaging.handling.AsyncCallbackService.AsyncCallbackMessageHandler | |
Summary
|
[Expand]
Inherited Fields | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
 From class
org.apache.helix.messaging.handling.MessageHandler
| |||||||||||
| Public Constructors | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
| Public Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
Message handling routine.
| |||||||||||
Callback when error happens in the message handling pipeline.
| |||||||||||
|
[Expand]
Inherited Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
|
From class
org.apache.helix.messaging.handling.MessageHandler
| |||||||||||
|
From class
java.lang.Object
| |||||||||||
Public Constructors
public AsyncCallbackService.AsyncCallbackMessageHandler (String correlationId, Message message, NotificationContext context)
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.
Throws
| InterruptedException |
|---|
public void onError (Exception e, MessageHandler.ErrorCode code, MessageHandler.ErrorType type)
Callback when error happens in the message handling pipeline.
Parameters
| type | TODO |
|---|