public abstract class MessageLoop extends Object implements Logging
Dispatcher
to deliver messages to endpoints.Constructor and Description |
---|
MessageLoop(org.apache.spark.rpc.netty.Dispatcher dispatcher) |
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) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public static org.apache.spark.rpc.netty.Inbox PoisonPill()
public abstract void post(String endpointName, InboxMessage message)
public abstract void unregister(String name)
public void stop()