spark-MessageHandler.adoc

MessageHandler

MessageHandler is a contract of message handlers that can handle messages.

package org.apache.spark.network.server;

abstract class MessageHandler<T extends Message> {
  abstract void handle(T message) throws Exception;
  abstract void channelActive();
  abstract void exceptionCaught(Throwable cause);
  abstract void channelInactive();
}

Table 1. MessageHandler Contract

Method	Description
handle	Used when…​FIXME
channelActive	Used when…​FIXME
exceptionCaught	Used when…​FIXME
channelInactive	Used when…​FIXME

Table 2. MessageHandlers

MessageHandler	Description
TransportRequestHandler
TransportResponseHandler