org.apache.spark.rpc.netty

Class MessageLoop

Object

org.apache.spark.rpc.netty.MessageLoop

All Implemented Interfaces:

Logging

Direct Known Subclasses:

DedicatedMessageLoop, SharedMessageLoop

public abstract class MessageLoop
extends Object
implements Logging

A message loop used by Dispatcher to deliver messages to endpoints.

Constructor Summary

Constructors

Constructor and Description
MessageLoop(org.apache.spark.rpc.netty.Dispatcher dispatcher)

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.rpc.netty.Inbox	PoisonPill() A poison inbox that indicates the message loop should stop processing messages.
abstract void	post(String endpointName, InboxMessage message)
void	stop()
abstract void	unregister(String name)

Methods inherited from class Object

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

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

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

Constructor Detail

MessageLoop

public MessageLoop(org.apache.spark.rpc.netty.Dispatcher dispatcher)

Method Detail

PoisonPill

public static org.apache.spark.rpc.netty.Inbox PoisonPill()

A poison inbox that indicates the message loop should stop processing messages.

post

public abstract void post(String endpointName,
                          InboxMessage message)

unregister

public abstract void unregister(String name)

stop

public void stop()