private final class MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread
extends java.lang.Thread
Constructor and Description |
---|
MulticastReceiverThread()
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
interrupt() |
private void |
processPayload(byte[] compressedPayload) |
private void |
processRmiUrls(java.lang.String rmiUrls)
This method forks a new executor to process the received heartbeat in a thread pool.
|
private void |
registerNotification(java.lang.String rmiUrl) |
void |
run() |
private boolean |
self(java.lang.String rmiUrls) |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public final void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
private void processPayload(byte[] compressedPayload)
private void processRmiUrls(java.lang.String rmiUrls)
rmiUrls
- private boolean self(java.lang.String rmiUrls)
rmiUrls
- private void registerNotification(java.lang.String rmiUrl)
public final void interrupt()
interrupt
in class java.lang.Thread