public final class MulticastKeepaliveHeartbeatReceiver
extends java.lang.Object
MulticastKeepaliveHeartbeatSender
s out there.
Our own multicast heartbeats are ignored.Modifier and Type | Class and Description |
---|---|
private class |
MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread
A multicast receiver which continously receives heartbeats.
|
Modifier and Type | Field and Description |
---|---|
private java.net.InetAddress |
groupMulticastAddress |
private java.lang.Integer |
groupMulticastPort |
private java.net.InetAddress |
hostAddress |
private static org.slf4j.Logger |
LOG |
private MulticastRMICacheManagerPeerProvider |
peerProvider |
private java.util.concurrent.ExecutorService |
processingThreadPool |
private MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread |
receiverThread |
private java.util.Set |
rmiUrlsProcessingQueue |
private java.net.MulticastSocket |
socket |
private boolean |
stopped |
Constructor and Description |
---|
MulticastKeepaliveHeartbeatReceiver(MulticastRMICacheManagerPeerProvider peerProvider,
java.net.InetAddress multicastAddress,
java.lang.Integer multicastPort,
java.net.InetAddress hostAddress)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
dispose()
Shutdown the heartbeat.
|
(package private) void |
init()
Start.
|
private static final org.slf4j.Logger LOG
private java.util.concurrent.ExecutorService processingThreadPool
private java.util.Set rmiUrlsProcessingQueue
private final java.net.InetAddress groupMulticastAddress
private final java.lang.Integer groupMulticastPort
private MulticastKeepaliveHeartbeatReceiver.MulticastReceiverThread receiverThread
private java.net.MulticastSocket socket
private volatile boolean stopped
private final MulticastRMICacheManagerPeerProvider peerProvider
private java.net.InetAddress hostAddress
public MulticastKeepaliveHeartbeatReceiver(MulticastRMICacheManagerPeerProvider peerProvider, java.net.InetAddress multicastAddress, java.lang.Integer multicastPort, java.net.InetAddress hostAddress)
peerProvider
- multicastAddress
- multicastPort
- hostAddress
-