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

results matching ""

    No results matching ""