org.apache.spark.rpc.netty

Class DedicatedMessageLoop

Object

org.apache.spark.rpc.netty.MessageLoop

org.apache.spark.rpc.netty.DedicatedMessageLoop

All Implemented Interfaces:

Logging

public class DedicatedMessageLoop
extends MessageLoop

A message loop that is dedicated to a single RPC endpoint.

Constructor Summary

Constructors

Constructor and Description
DedicatedMessageLoop(String name, IsolatedRpcEndpoint endpoint, org.apache.spark.rpc.netty.Dispatcher dispatcher)

Method Summary

Modifier and Type	Method and Description
void	post(String endpointName, InboxMessage message)
void	unregister(String endpointName)

Methods inherited from class org.apache.spark.rpc.netty.MessageLoop

PoisonPill, stop

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.internal.Logging

initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

DedicatedMessageLoop

public DedicatedMessageLoop(String name,
                            IsolatedRpcEndpoint endpoint,
                            org.apache.spark.rpc.netty.Dispatcher dispatcher)

Method Detail

post

public void post(String endpointName,
                 InboxMessage message)

Specified by:

post in class MessageLoop

unregister

public void unregister(String endpointName)

Specified by:

unregister in class MessageLoop